TriggerSavepoint

TriggerSavepoint

Create a savepoint for a running Flink job

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 *string

restUrl *string

cancelJob booleanstring

Defaultfalse

formatType string

DefaultCANONICAL

savepointTimeout integerstring

Default300

targetDirectory string

Outputs

jobId string

requestId string

savepointPath string

Apache Cassandra

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Data

Git

Tasks that clone, fetch, and interact with Git repositories.

InfrastructureBusiness

MongoDB

Tasks that query and manipulate MongoDB collections.

Data

TriggerSavepoint

Create a savepoint for a running Flink job

More Plugins in this Category

Apache Cassandra

Git

MongoDB

1.4.0

TriggerSavepoint Create a savepoint for a running Flink job

More Plugins in this Category

Apache Cassandra

Git

MongoDB

1.4.0

TriggerSavepoint

Create a savepoint for a running Flink job