(fluss) branch main updated: [hotfix][client] Retry to initial cluster when encounter TimeoutException (#2055)

[jark]

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

jark 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 b7203a7fd [hotfix][client] Retry to initial cluster when encounter 
TimeoutException (#2055)
b7203a7fd is described below

commit b7203a7fd59f9394b34a713213cb81e801f4e253
Author: yunhong <337361...@qq.com>
AuthorDate: Sun Nov 30 15:17:12 2025 +0800

    [hotfix][client] Retry to initial cluster when encounter TimeoutException 
(#2055)
---
 .../main/java/org/apache/fluss/client/metadata/MetadataUpdater.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/fluss-client/src/main/java/org/apache/fluss/client/metadata/MetadataUpdater.java
 
b/fluss-client/src/main/java/org/apache/fluss/client/metadata/MetadataUpdater.java
index b47e709b8..0c61eb5fd 100644
--- 
a/fluss-client/src/main/java/org/apache/fluss/client/metadata/MetadataUpdater.java
+++ 
b/fluss-client/src/main/java/org/apache/fluss/client/metadata/MetadataUpdater.java
@@ -336,7 +336,9 @@ public class MetadataUpdater {
             } catch (Exception e) {
                 Throwable cause = stripExecutionException(e);
                 // in case of bootstrap is recovering, we should retry to 
connect.
-                if (!(cause instanceof StaleMetadataException || cause 
instanceof NetworkException)
+                if (!(cause instanceof StaleMetadataException
+                                || cause instanceof NetworkException
+                                || cause instanceof TimeoutException)
                         || retryCount >= maxRetryTimes) {
                     throw e;
                 }