From ce4330d62b9f2ecd58d9c81b316a56ab3f4d6abe Mon Sep 17 00:00:00 2001 From: Danny Chan Date: Fri, 29 Jul 2022 15:01:29 +0800 Subject: [PATCH] [HUDI-4499] Tweak default retry times for flink metadata table lock (#6238) --- .../src/main/java/org/apache/hudi/util/StreamerUtil.java | 1 + 1 file changed, 1 insertion(+) 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 b3c054b32d3f..4e819ecd7b93 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 static HoodieWriteConfig getHoodieClientConfig( .withLockProvider(FileSystemBasedLockProvider.class) .withLockWaitTimeInMillis(2000L) // 2s .withFileSystemLockExpire(1) // 1 minute + .withClientNumRetries(30) .withFileSystemLockPath(StreamerUtil.getAuxiliaryPath(conf)) .build()) .withPayloadConfig(HoodiePayloadConfig.newBuilder()