diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
index b3c054b32..4e819ecd7 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -225,6 +225,7 @@ public class StreamerUtil {
                 .withLockProvider(FileSystemBasedLockProvider.class)
                 .withLockWaitTimeInMillis(2000L) // 2s
                 .withFileSystemLockExpire(1) // 1 minute
+                .withClientNumRetries(30)
                 .withFileSystemLockPath(StreamerUtil.getAuxiliaryPath(conf))
                 .build())
             .withPayloadConfig(HoodiePayloadConfig.newBuilder()