(fluss) branch main updated: Fix inverted awaitTermination condition in LookupClient#close (#3328)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

luoyuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 0dcb0a7db Fix inverted awaitTermination condition in 
LookupClient#close (#3328)
0dcb0a7db is described below

commit 0dcb0a7db971bfec23680f55b2c9b460f63d1be1
Author: ForwardXu <forwar...@apache.org>
AuthorDate: Mon Jun 15 12:12:26 2026 +0800

    Fix inverted awaitTermination condition in LookupClient#close (#3328)
---
 .../src/main/java/org/apache/fluss/client/lookup/LookupClient.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 7e2798294..47b15b1d5 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 class LookupClient {
         if (lookupSenderThreadPool != null) {
             lookupSenderThreadPool.shutdown();
             try {
-                if (lookupSenderThreadPool.awaitTermination(
+                if (!lookupSenderThreadPool.awaitTermination(
                         timeout.toMillis(), TimeUnit.MILLISECONDS)) {
                     lookupSenderThreadPool.shutdownNow();