Apache FlinkApache Flink
Apache FlinkCertified

Tasks that submit, monitor, cancel, and trigger savepoints for Apache Flink jobs over the REST API.

Provide the Flink JobManager REST restUrl plus job details such as jarUri, entryClass, args, parallelism, and optional savepoint paths to upload and run jobs, monitor status, cancel executions, or trigger savepoints directly from Kestra.

tasks

CancelJob

Cancel a running Flink job.

io.kestra.plugin.flink.CancelJob
Submit

Submit a Flink job using a JAR file.

io.kestra.plugin.flink.Submit
SubmitSql

Submit a SQL statement to Flink SQL Gateway.

io.kestra.plugin.flink.SubmitSql
TriggerSavepoint

Trigger a savepoint for a running Flink job.

io.kestra.plugin.flink.TriggerSavepoint

triggers

MonitorJob

Monitor a Flink job and trigger flow execution on state changes.

io.kestra.plugin.flink.MonitorJob

More Plugins in this Category

Azure
Azure

Leverage Microsoft Azure services within Kestra data workflows.

CloudMessagingStorageBatchTool

37 Tasks

2 Blueprints

Cryptography
Cryptography

Tasks that secure files in Kestra pipelines using OpenPGP encryption, decryption, and signature validation.

Transformation

2 Tasks

Google Cloud (EE)
Google Cloud
Enterprise

Integrate Google Cloud Platform services with Kestra data workflows.

StorageCloudAlertingBatch

4 Tasks

OVERVIEW
Versions
1.1.1
Latest
December 31, 2025 Release Notes Min. Compatible Kestra Version: 1.0.0
Previous Versions
1.1.0November 3, 2025 Min. Compatible Kestra Version: 1.0.0

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
TransformationBatch
Links & Resources
GitHub