Hi, team.

      The SubmittedJobGraph file record savepoint restorepath info.
      But this restorePath will not be updated when a new savepoint be 
generated.
     I use the parameter kubernetes.operator.periodic.savepoint.interval  to 
generate new savepoints periodically,
     but submittedJobGraph restorePath will not be updated.

    Do we have a plan to implement this function that  update the savepoint 
restorePath in the SubmittedJobGraph file on a regular basis .
    If we have already implemented this function, could you tell me how to 
configure it?


For example:
     [cid:398ccc31-514f-49e8-af68-2e5c9eacc371]

    
SavepointRestoreSettings.forPath(restorePath='s3://flink/savepoint/etl/savepoint-9b2a85',
 allowNonRestoredState=false)

Reply via email to