You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "tanjialiang (Jira)" <ji...@apache.org> on 2021/12/20 10:37:00 UTC

[jira] [Created] (FLINK-25384) Job can not migrate from flink-1.12 to flink-1.13

tanjialiang created FLINK-25384:
-----------------------------------

             Summary: Job can not migrate from flink-1.12 to flink-1.13
                 Key: FLINK-25384
                 URL: https://issues.apache.org/jira/browse/FLINK-25384
             Project: Flink
          Issue Type: Technical Debt
          Components: Table SQL / Planner
    Affects Versions: 1.14.0, 1.13.0
            Reporter: tanjialiang


The NotNullEnforcer is always add in the Flink-1.12. But in this [PR|https://issues.apache.org/jira/browse/FLINK-21005], it make a IF branch to make a decision whether the NotNullEnforcer to add.

 

So it make the StreamGraph change in flink-1.13. So i think this is the reason i can't migrate the flink sql job from flink-1.12 to flink-1.13. :(

 

Solution：make a table sink's column to be NOT NULL, so that it can add a NotNullEnforcer operator in to the stream graph, that will work in restore from savepoint between flink-1.12 to flink-1.13.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)