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)