yuchengxin commented on code in PR #22767:
URL: https://github.com/apache/flink/pull/22767#discussion_r1264960465
##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java:
##########
@@ -146,7 +146,18 @@ public final class FactoryUtil {
ConfigOptions.key("scan.watermark.alignment.update-interval")
.durationType()
.defaultValue(Duration.ofMillis(1000))
- .withDescription("update interval to align watermark.");
+ .withDescription("Update interval to align watermark.");
+
+ public static final ConfigOption<Duration> SOURCE_IDLE_TIMEOUT =
+ ConfigOptions.key("scan.watermark.idle-timeout")
+ .durationType()
+ .noDefaultValue()
+ .withDescription(
+ "When a source do not receive any elements for the
timeout time, "
+ + "it will be marked as temporarily idle.
This allows downstream "
+ + "tasks to advance their watermarks
without the need to wait for "
+ + "watermarks from this source while it is
idle. "
+ + "Default value is 0, which means
detecting source idleness is not enabled.");
Review Comment:
modified
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
