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

) Signed-off-by: Ning Yu <[email protected]>
AutoMQ · Nov 8, 2024 · fb5bce8 · fb5bce8
1 parent 37e1af5
commit fb5bce8
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) {