[jira] [Created] (FLINK-23962) UpdateKind trait is not propagated properly in changeLog inference for DAG optimizing

["Shuo Cheng (Jira)" <ji...@apache.org>]

Shuo Cheng created FLINK-23962:
----------------------------------

             Summary: 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.13.2, 1.14.0
            Reporter: Shuo Cheng
             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)