[ 
https://issues.apache.org/jira/browse/FLINK-29588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616041#comment-17616041
 ] 

Clara Xiong commented on FLINK-29588:
-------------------------------------

appVersion is the application version of the FlinkDeployment.

If a user doesn't find a problem until after a couple of rounds of upgrades and 
decides to go back to re-process or troubleshoot, they have already had many 
savepoints taken. Timestamp is a way to look for the right one but they 
probably need a way to keep the chronological history of versions. 

> Add Flink Version and Application Version to Savepoint properties
> -----------------------------------------------------------------
>
>                 Key: FLINK-29588
>                 URL: https://issues.apache.org/jira/browse/FLINK-29588
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kubernetes Operator
>            Reporter: Clara Xiong
>            Priority: Major
>
> It is common that users need to upgrade long running FlinkDeployment's. An 
> application upgrade or a major Flink upgrade might break the applications due 
> to schema incompatibilities, especially the 
> latter([Link)|https://nightlies.apache.org/flink/flink-docs-master/docs/ops/upgrading/#compatibility-table].
>  In this case, the users need to manually restore to a savepoint that is 
> compatible with the version the user wants to try or re-process. Currently 
> Flink Operator returns a list of completed Savepoint's for a FlinkDeployment. 
>  It will be helpful that the Savepoint's in SavepointHistory have the 
> properties for Flink Version and application version so users can easily 
> determine which savepoint to use.
>  
>  * {{String flinkVersion}}
>  * {{String appVersion}}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to