TriggerSavepoint TriggerSavepoint
TriggerSavepoint Certified

yaml
type: "io.kestra.plugin.flink.TriggerSavepoint"
yaml
id: create-savepoint
namespace: company.team

tasks:
  - id: trigger-savepoint
    type: io.kestra.plugin.flink.TriggerSavepoint
    restUrl: "http://flink-jobmanager:8081"
    jobId: "{{ inputs.jobId }}"
    targetDirectory: "s3://flink/savepoints/backup/{{ execution.id }}"
    savepointTimeout: 300

yaml
id: "triggersavepoint"
type: "io.kestra.plugin.flink.TriggerSavepoint"
id: default-savepoint
type: io.kestra.plugin.flink.TriggerSavepoint
restUrl: "http://flink-jobmanager:8081"
jobId: "{{ inputs.jobId }}"
Properties
Defaultfalse
DefaultCANONICAL
Default300