[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-23962:
---------------------------------
Priority: Blocker (was: Major)
> 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.14.0, 1.13.2
> Reporter: Shuo Cheng
> Assignee: Shuo Cheng
> Priority: Blocker
> Fix For: 1.14.0, 1.13.3
>
>
> 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.
>
> -> block3
> block0 -> block1 -> block4
> -> block2
>
> In the above example, if block3 requires UB and block2, block4 do not require
> UB, block1 only contains Calc node.
> 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)
