Skip to content

Commit 9659bfe

Browse files
committed
[HUDI-4499] Tweak default retry times for flink metadata table lock
1 parent c39e88d commit 9659bfe

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -225,6 +225,7 @@ public static HoodieWriteConfig getHoodieClientConfig(
225225
.withLockProvider(FileSystemBasedLockProvider.class)
226226
.withLockWaitTimeInMillis(2000L) // 2s
227227
.withFileSystemLockExpire(1) // 1 minute
228+
.withClientNumRetries(30)
228229
.withFileSystemLockPath(StreamerUtil.getAuxiliaryPath(conf))
229230
.build())
230231
.withPayloadConfig(HoodiePayloadConfig.newBuilder()

0 commit comments

Comments
 (0)