TriggerSavepoint
TriggerSavepoint
yaml
type: "io.kestra.plugin.flink.TriggerSavepoint"Examples
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
jobId *Requiredstring
restUrl *Requiredstring
cancelJob booleanstring
Default
falseformatType string
Default
CANONICALsavepointTimeout integerstring
Default
300