[
https://issues.apache.org/jira/browse/FLINK-25384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463544#comment-17463544
]
tanjialiang edited comment on FLINK-25384 at 12/22/21, 2:56 AM:
----------------------------------------------------------------
[~twalthr] Thanks for your reply. It's LGTM.
was (Author: JIRAUSER279823):
[~twalthr]Thanks for your reply. It's LGTM.
> 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)
