[
https://issues.apache.org/jira/browse/FLINK-25384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tanjialiang updated FLINK-25384:
--------------------------------
Description:
The NotNullEnforcer is always add in the Flink-1.12. But in this PR, 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.
was:
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.
> 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.13.0, 1.14.0
> Reporter: tanjialiang
> Priority: Major
>
> The NotNullEnforcer is always add in the Flink-1.12. But in this PR, 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)
