Skip to content

Commit 40ff4c8

Browse files
committed
[hotfix][client] Retry to initial cluster when encounter TimeoutException
1 parent c5257fd commit 40ff4c8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

fluss-client/src/main/java/org/apache/fluss/client/metadata/MetadataUpdater.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -336,7 +336,9 @@ private static Cluster initializeCluster(Configuration conf, RpcClient rpcClient
336336
} catch (Exception e) {
337337
Throwable cause = stripExecutionException(e);
338338
// in case of bootstrap is recovering, we should retry to connect.
339-
if (!(cause instanceof StaleMetadataException || cause instanceof NetworkException)
339+
if (!(cause instanceof StaleMetadataException
340+
|| cause instanceof NetworkException
341+
|| cause instanceof TimeoutException)
340342
|| retryCount >= maxRetryTimes) {
341343
throw e;
342344
}

0 commit comments

Comments
 (0)