chore(all): adapt to java21 (AutoMQ#1471)

Signed-off-by: Robin Han <hanxvdovehx@gmail.com>
szepeviktor · Jun 27, 2024 · 96edd72 · 96edd72
1 parent 5df678a
commit 96edd72
Show file tree

Hide file tree

Showing 28 changed files with 14 additions and 3,331 deletions.
diff --git a/metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java
@@ -101,7 +101,7 @@
 /**
  * The StreamControlManager manages all Stream's lifecycle, such as create, open, delete, etc.
  */
-@SuppressWarnings("all")
+@SuppressWarnings({"all", "this-escape"})
 public class StreamControlManager {
     private static final Logger LOGGER = LoggerFactory.getLogger(StreamControlManager.class);
 

diff --git a/metadata/src/main/java/org/apache/kafka/controller/stream/TopicDeletionManager.java b/metadata/src/main/java/org/apache/kafka/controller/stream/TopicDeletionManager.java
@@ -43,6 +43,7 @@
  * 3. {@link TopicDeletionManager} schedule scan the waiting cleanup topics and delete the streams related to topic
  * 4. After the streams related to the topic are deleted, {@link TopicDeletionManager} generate RemoveKvRecord to remove the topicId from {@link TopicDeletionManager#waitingCleanupTopics}
  */
+@SuppressWarnings("this-escape")
 public class TopicDeletionManager {
     private static final Logger LOGGER = LoggerFactory.getLogger(TopicDeletionManager.class);
     final TimelineHashMap<Uuid, Status> waitingCleanupTopics;

diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java b/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java
@@ -121,6 +121,7 @@ public class S3Storage implements Storage {
     private long lastLogTimestamp = 0L;
     private volatile double maxDataWriteRate = 0.0;
 
+    @SuppressWarnings("this-escape")
     public S3Storage(Config config, WriteAheadLog deltaWAL, StreamManager streamManager, ObjectManager objectManager,
         S3BlockCache blockCache, ObjectStorage objectStorage) {
         this.config = config;

diff --git a/s3stream/src/main/java/com/automq/stream/s3/cache/BlockCache.java b/s3stream/src/main/java/com/automq/stream/s3/cache/BlockCache.java
diff --git a/s3stream/src/main/java/com/automq/stream/s3/cache/DataBlockReadAccumulator.java b/s3stream/src/main/java/com/automq/stream/s3/cache/DataBlockReadAccumulator.java
diff --git a/s3stream/src/main/java/com/automq/stream/s3/cache/DataBlockRecords.java b/s3stream/src/main/java/com/automq/stream/s3/cache/DataBlockRecords.java