[
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.
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.
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.
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.
> 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, 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)
