This is an automated email from the ASF dual-hosted git repository.
jchan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6dbe7bf5c306551836ec89c70f9aaab317f55e10
Author: Jane Chan <qingyue....@gmail.com>
AuthorDate: Tue Jun 4 17:50:53 2024 +0800
[FLINK-35473][table-planner] Add issue navigator to track legacy window
options
This closes #24889
---
.../planner/plan/utils/WindowEmitStrategy.scala | 25 +++++++++++++++++-----
1 file changed, 20 insertions(+), 5 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala
index 50becc11a0d..1e841c0722e 100644
---
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala
+++
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala
@@ -191,7 +191,10 @@ object WindowEmitStrategy {
}
}
- // It is a experimental config, will may be removed later.
+ /**
+ * It is an experimental config, and its removal will be consistently
monitored and addressed
+ * through FLINK-29692.
+ */
@Experimental
val TABLE_EXEC_EMIT_EARLY_FIRE_ENABLED: ConfigOption[JBoolean] =
key("table.exec.emit.early-fire.enabled")
@@ -200,7 +203,10 @@ object WindowEmitStrategy {
.withDescription("Specifies whether to enable early-fire emit." +
"Early-fire is an emit strategy before watermark advanced to end of
window.")
- // It is a experimental config, will may be removed later.
+ /**
+ * It is an experimental config, and its removal will be consistently
monitored and addressed
+ * through FLINK-29692.
+ */
@Experimental
val TABLE_EXEC_EMIT_EARLY_FIRE_DELAY: ConfigOption[Duration] =
key("table.exec.emit.early-fire.delay")
@@ -213,7 +219,10 @@ object WindowEmitStrategy {
"0 means no delay (fire on every element). " +
"> 0 means the fire interval. ")
- // It is a experimental config, will may be removed later.
+ /**
+ * It is an experimental config, and its removal will be consistently
monitored and addressed
+ * through FLINK-29692.
+ */
@Experimental
val TABLE_EXEC_EMIT_LATE_FIRE_ENABLED: ConfigOption[JBoolean] =
key("table.exec.emit.late-fire.enabled")
@@ -222,7 +231,10 @@ object WindowEmitStrategy {
.withDescription("Specifies whether to enable late-fire emit. " +
"Late-fire is an emit strategy after watermark advanced to end of
window.")
- // It is a experimental config, will may be removed later.
+ /**
+ * It is an experimental config, and its removal will be consistently
monitored and addressed
+ * through FLINK-29692.
+ */
@Experimental
val TABLE_EXEC_EMIT_LATE_FIRE_DELAY: ConfigOption[Duration] =
key("table.exec.emit.late-fire.delay")
@@ -235,7 +247,10 @@ object WindowEmitStrategy {
"0 means no delay (fire on every element). " +
"> 0 means the fire interval.")
- // It is a experimental config, will may be removed later.
+ /**
+ * It is an experimental config, and its removal will be consistently
monitored and addressed
+ * through FLINK-29692.
+ */
@Experimental
val TABLE_EXEC_EMIT_ALLOW_LATENESS: ConfigOption[Duration] =
key("table.exec.emit.allow-lateness")
