Added consumedOptions annotation in StreamExecTemporalJoin

apache · Dec 13, 2024 · 5685f1f · 5685f1f
1 parent 200f52f
commit 5685f1f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...in/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTemporalJoin.java b/...in/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTemporalJoin.java
@@ -74,6 +74,7 @@
         name = "stream-exec-temporal-join",
         version = 1,
         producedTransformations = StreamExecTemporalJoin.TEMPORAL_JOIN_TRANSFORMATION,
+        consumedOptions = {"table.exec.async-state.enabled"},
         minPlanVersion = FlinkVersion.v1_15,
         minStateVersion = FlinkVersion.v1_15)
 public class StreamExecTemporalJoin extends ExecNodeBase<RowData>