diff --git a/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupClient.java b/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupClient.java index 7e27982941..47b15b1d53 100644 --- a/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupClient.java +++ b/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupClient.java @@ -122,7 +122,7 @@ public void close(Duration timeout) { if (lookupSenderThreadPool != null) { lookupSenderThreadPool.shutdown(); try { - if (lookupSenderThreadPool.awaitTermination( + if (!lookupSenderThreadPool.awaitTermination( timeout.toMillis(), TimeUnit.MILLISECONDS)) { lookupSenderThreadPool.shutdownNow();