You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Sep 2, 2022. It is now read-only.
Currently when taking savepoint, users specify a savepoints (parent) dir, Flink automatically generate a savepoint ID and put data in the corresponding subdir. When starting a job from a savepoint, you have to specify the savepoint ID, which means when using the operator, the job args part of the CR has to be changed to point to the specific savepoint.
We want to allow users to only specify savepoints dir in jobSpec, and the operator automatically selects (the latest) savepoint in the dir. This will in turn allow us to update job seamlessly, because savepoint ID becomes transparent.
The text was updated successfully, but these errors were encountered:
Currently when taking savepoint, users specify a savepoints (parent) dir, Flink automatically generate a savepoint ID and put data in the corresponding subdir. When starting a job from a savepoint, you have to specify the savepoint ID, which means when using the operator, the job args part of the CR has to be changed to point to the specific savepoint.
We want to allow users to only specify savepoints dir in jobSpec, and the operator automatically selects (the latest) savepoint in the dir. This will in turn allow us to update job seamlessly, because savepoint ID becomes transparent.
The text was updated successfully, but these errors were encountered: