[jira] [Commented] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec
[ https://issues.apache.org/jira/browse/FLINK-27458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531201#comment-17531201 ] Yang Wang commented on FLINK-27458: --- This is a reasonable improvement. +1 to introduce this field. > Expose allowNonRestoredState flag in JobSpec > > > Key: FLINK-27458 > URL: https://issues.apache.org/jira/browse/FLINK-27458 > Project: Flink > Issue Type: Improvement > Components: Kubernetes Operator >Reporter: Gyula Fora >Assignee: Aitozi >Priority: Major > Fix For: kubernetes-operator-1.0.0 > > > We should probably expose this option as a top level spec field otherwise it > is impossible to set this on a per job level for SessionJobs. > What do you think [~aitozi] [~wangyang0918] -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec
[ https://issues.apache.org/jira/browse/FLINK-27458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530394#comment-17530394 ] Gyula Fora commented on FLINK-27458: Yes we need to set the conf value for application mode to be consistent:) > Expose allowNonRestoredState flag in JobSpec > > > Key: FLINK-27458 > URL: https://issues.apache.org/jira/browse/FLINK-27458 > Project: Flink > Issue Type: Improvement > Components: Kubernetes Operator >Reporter: Gyula Fora >Priority: Major > Fix For: kubernetes-operator-1.0.0 > > > We should probably expose this option as a top level spec field otherwise it > is impossible to set this on a per job level for SessionJobs. > What do you think [~aitozi] [~wangyang0918] -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec
[ https://issues.apache.org/jira/browse/FLINK-27458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530382#comment-17530382 ] Aitozi commented on FLINK-27458: I am willing to work on this > Expose allowNonRestoredState flag in JobSpec > > > Key: FLINK-27458 > URL: https://issues.apache.org/jira/browse/FLINK-27458 > Project: Flink > Issue Type: Improvement > Components: Kubernetes Operator >Reporter: Gyula Fora >Priority: Major > Fix For: kubernetes-operator-1.0.0 > > > We should probably expose this option as a top level spec field otherwise it > is impossible to set this on a per job level for SessionJobs. > What do you think [~aitozi] [~wangyang0918] -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec
[ https://issues.apache.org/jira/browse/FLINK-27458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530381#comment-17530381 ] Aitozi commented on FLINK-27458: The application job can set {{execution.savepoint.ignore-unclaimed-state: true}} to skip the unclaimed state. But the session job can not touch the cluster flink conf, So I think exposing allowNonRestoredState flag in JobSpec is reasonable. BTW, If this value set to true, I think we should also set the {{execution.savepoint.ignore-unclaimed-state}} to true for application mode, WDYT ? > Expose allowNonRestoredState flag in JobSpec > > > Key: FLINK-27458 > URL: https://issues.apache.org/jira/browse/FLINK-27458 > Project: Flink > Issue Type: Improvement > Components: Kubernetes Operator >Reporter: Gyula Fora >Priority: Major > Fix For: kubernetes-operator-1.0.0 > > > We should probably expose this option as a top level spec field otherwise it > is impossible to set this on a per job level for SessionJobs. > What do you think [~aitozi] [~wangyang0918] -- This message was sent by Atlassian Jira (v8.20.7#820007)