lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

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

Browse Source
This commit is contained in:
Danny Chan
2022-07-29 15:01:29 +08:00
committed by GitHub
parent c39e88dcf0
commit ce4330d62b
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -225,6 +225,7 @@ public class StreamerUtil {
.withLockProvider(FileSystemBasedLockProvider.class) .withLockProvider(FileSystemBasedLockProvider.class)
.withLockWaitTimeInMillis(2000L) // 2s .withLockWaitTimeInMillis(2000L) // 2s
.withFileSystemLockExpire(1) // 1 minute .withFileSystemLockExpire(1) // 1 minute
.withClientNumRetries(30)
.withFileSystemLockPath(StreamerUtil.getAuxiliaryPath(conf)) .withFileSystemLockPath(StreamerUtil.getAuxiliaryPath(conf))
.build()) .build())
.withPayloadConfig(HoodiePayloadConfig.newBuilder() .withPayloadConfig(HoodiePayloadConfig.newBuilder()