From 73e89012daf9725aa0a60e925805058b322dd7ab Mon Sep 17 00:00:00 2001
From: Yu Ning <78631860+Chillax-0v0@users.noreply.github.com>
Date: Fri, 8 Nov 2024 11:13:03 +0800
Subject: [PATCH] fix(s3stream/storage): correct if condition on
 `awaitTermination` (#2138)

Signed-off-by: Ning Yu <ningyu@automq.com>
---
 s3stream/src/main/java/com/automq/stream/s3/S3Storage.java | 2 +-
 1 file changed, 1 insertion(+), 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
index f49161726e..324662cf46 100644
--- 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) {