fix(kafka_issues491): ignore await after scheduled task cancel (#770)

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Mar 14, 2024 · 7e87abe · 7e87abe
1 parent ae5cfb1
commit 7e87abe
Showing 1 changed file with 0 additions 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
@@ -233,7 +233,6 @@ static LogCache.LogCacheBlock recoverContinuousRecords(Iterator<WriteAheadLog.Re
     @Override
     public void shutdown() {
         drainBackoffTask.cancel(false);
-        FutureUtil.suppress(drainBackoffTask::get, LOGGER);
         for (WalWriteRequest request : backoffRecords) {
             request.cf.completeExceptionally(new IOException("S3Storage is shutdown"));
         }