Apache FlinkApache Flink
Apache FlinkCertified

This sub-group of plugins contains tasks for orchestrating Apache Flink jobs, including job submission, monitoring, and savepoint management.

tasks

CancelJob
io.kestra.plugin.flink.CancelJob
Submit
io.kestra.plugin.flink.Submit
SubmitSql
io.kestra.plugin.flink.SubmitSql
TriggerSavepoint
io.kestra.plugin.flink.TriggerSavepoint

triggers

MonitorJob
io.kestra.plugin.flink.MonitorJob

More Plugins in this Category

Compression
Compression

Tasks that compress and decompress files and archives for Kestra flows.

Transformation

4 Tasks

4 Blueprints

Azure (EE)
Azure
Enterprise

Leverage Microsoft Azure services within Kestra data workflows.

AlertingCloudStorageBatch

6 Tasks

JSONata
JSONata

Kestra Plugin Transformation for Json.

Transformation

2 Tasks

OVERVIEW
Versions
1.1.0
Latest
November 3, 2025 Release Notes

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
TransformationBatch
Links & Resources
Github