[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-23962.
------------------------------
Fix Version/s: 1.15.0
Resolution: Fixed
Fixed in 1.15.0: ffd2520620069840b88cde72e2f02fd99a96ea70
Fixed in 1.14.0: d08e10849fd711cf375fcfbf05b9e1fe6d6ce94f
Fixed in 1.13.3: e81e73e55ccc6797a768e98f6ffaa135122a2bec
> 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
> Labels: pull-request-available
> Fix For: 1.14.0, 1.13.3, 1.15.0
>
>
> 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)
