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:21a8a66f-263b-4b67-9af4-c1a07b2da293]

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


Reply via email to