wangyang0918 edited a comment on pull request #139: URL: https://github.com/apache/flink-kubernetes-operator/pull/139#issuecomment-1085605936
> for the jobs that enable the checkpoint via StreamExecutionEnvironment.enableCheckpointing(), we could guide the user to use the configuration method to open checkpoint. This will not work for session clusters since each job has different checkpoint interval. > in Flink, when calling the StreamExecutionEnvironment.enableCheckpointing(), the execution.checkpointing.interval should be set with value of the interval for enableCheckpointing(). This is impossible to set the value to flink config in the CR. What I am thinking is to add a default value for `execution.checkpointing.interval` when last-state upgrade mode is used. It could be overridden by user specified CR or `StreamExecutionEnvironment.enableCheckpointing()`. Then we do not force users should set it explicitly in the CR. @SteNicholas @gyfora WDYT? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
