[HUDI-4499] Tweak default retry times for flink metadata table lock (#…

…6238)
apache · Jul 29, 2022 · ce4330d · ce4330d
1 parent c39e88d
commit ce4330d
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -225,6 +225,7 @@ public static HoodieWriteConfig getHoodieClientConfig(
                 .withLockProvider(FileSystemBasedLockProvider.class)
                 .withLockWaitTimeInMillis(2000L) // 2s
                 .withFileSystemLockExpire(1) // 1 minute
+                .withClientNumRetries(30)
                 .withFileSystemLockPath(StreamerUtil.getAuxiliaryPath(conf))
                 .build())
             .withPayloadConfig(HoodiePayloadConfig.newBuilder()