[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404241#comment-17404241
]
Caizhi Weng commented on FLINK-23962:
-------------------------------------
This seems to be a bug that affects the correctness of data. Shall we make it a
blocker [~lzljs3620320] [~godfreyhe] ?
> 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
> Priority: Major
> 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, if block3 requires UB and 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)
