fix(s3stream/storage): correct if condition on awaitTermination (#2138

) Signed-off-by: Ning Yu <ningyu@automq.com>
AutoMQ · Nov 8, 2024 · 73e8901 · 73e8901
1 parent 8f5fcc5
commit 73e8901
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java b/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java
@@ -397,7 +397,7 @@ public void shutdown() {
         deltaWAL.shutdownGracefully();
         backgroundExecutor.shutdown();
         try {
-            if (backgroundExecutor.awaitTermination(10, TimeUnit.SECONDS)) {
+            if (!backgroundExecutor.awaitTermination(10, TimeUnit.SECONDS)) {
                 LOGGER.warn("await backgroundExecutor timeout 10s");
             }
         } catch (InterruptedException e) {