From 834668b830e6d81bd8cfea2a5ec3494bd426e8cf Mon Sep 17 00:00:00 2001 From: PengFei Li Date: Fri, 18 Aug 2023 15:22:43 +0800 Subject: [PATCH] [Enhancement] Increase default sink.connect.timeout-ms to to tolerate jitter Signed-off-by: PengFei Li --- .../connector/flink/table/sink/StarRocksSinkOptions.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java b/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java index 78fe1786..e0fac69c 100644 --- a/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java +++ b/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksSinkOptions.java @@ -81,7 +81,7 @@ public enum StreamLoadFormat { public static final ConfigOption SINK_LABEL_PREFIX = ConfigOptions.key("sink.label-prefix") .stringType().noDefaultValue().withDescription("The prefix of the stream load label. Available values are within [-_A-Za-z0-9]"); public static final ConfigOption SINK_CONNECT_TIMEOUT = ConfigOptions.key("sink.connect.timeout-ms") - .intType().defaultValue(1000).withDescription("Timeout in millisecond for connecting to the `load-url`."); + .intType().defaultValue(30000).withDescription("Timeout in millisecond for connecting to the `load-url`."); public static final ConfigOption SINK_WAIT_FOR_CONTINUE_TIMEOUT = ConfigOptions.key("sink.wait-for-continue.timeout-ms") .intType().defaultValue(30000).withDescription("Timeout in millisecond to wait for 100-continue response for http client."); public static final ConfigOption SINK_IO_THREAD_COUNT = ConfigOptions.key("sink.io.thread-count")