[
https://issues.apache.org/jira/browse/FLINK-23962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng updated FLINK-23962:
-------------------------------
Description:
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 does 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.
was:
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 does 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.
> 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.
>
> \-> block3
> block0 -> block1 -> block4
> \-> block2
>
> In the above example, if block3 requires UB and block2 does 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)
