Shuo Cheng created FLINK-23962:
----------------------------------
Summary: UpdateKind trait is not propagated properly in changeLog
inference for DAG optimizing
Key: FLINK-23962
URL: https://issues.apache.org/jira/browse/FLINK-23962
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.13.2, 1.14.0
Reporter: Shuo Cheng
Fix For: 1.13.3, 1.14.1
For sql jobs with multi-sinks, the plan is divided into relNode blocks,
changeLog mode should be also inferred among blocks. Currently, updateKind
trait is not propagated properly from parent block to child blocks for the
following pattern.
block0 -> block1 -> block3
\-> block2
In the above example, block3 requies UB, block2 does not require UB.
For Agg in block0, UB should be emitted, but the updateKind for block0 is
inferred as
ONLY_UPDATE_AFTER.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
