elkhand commented on issue #2033: URL: https://github.com/apache/iceberg/issues/2033#issuecomment-767068712
Tried this: https://flink.apache.org/news/2019/08/22/release-1.9.0.html#stop-with-savepoint-flip-34 Stop-with-Savepoint (FLIP-34) `Cancelling with a savepoint` ``` bin/flink stop -p [:targetDirectory] :jobId ``` This **did not** work, seems `endInput()` was still called and `flink.max-committed-checkpoint-id` set to `Long.MAX_VALUE`. The deprecated method `bin/flink cancel -s [:targetDirectory] :jobId` **works correctly** though: https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/savepoints.html#cancel-job-with-savepoint This will atomically trigger a savepoint for the job with ID :jobid and cancel the job. ``` bin/flink cancel -s /tmp/flink-savepoints d76df1dca8592a2901f82af7ae510f75 DEPRECATION WARNING: Cancelling a job with savepoint is deprecated. Use "stop" instead. Cancelling job d76df1dca8592a2901f82af7ae510f75 with savepoint to /tmp/flink-savepoints. Cancelled job d76df1dca8592a2901f82af7ae510f75. Savepoint stored in file:/tmp/flink-savepoints/savepoint-d76df1-fba95e37a600. ``` ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
