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)
