Re: Version Upgrade of FlinkSQL (1.10 to 1.12)

2022-03-04 Thread zihao chen
m/MartijnVisser82 > > [1] > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/concepts/overview/#stateful-upgrades-and-evolution > [2] > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=191336489 > > > On Fri, 4 Mar 2022 at 04:23, zihao chen wrote: >

Version Upgrade of FlinkSQL (1.10 to 1.12)

2022-03-03 Thread zihao chen
hi, All. I would like to upgrade the Flink version of several FlinkSQLs from 1.10 to 1.12. And I want to restore the state saved by version 1.10 on version 1.12. After I look at the StreamGraph, JobGraph, Checkpoint and some other related informations, I found these points that would cause the