Apache Beam Apache Beam
Apache Beam Certified

Tasks that run pipelines against SDKs and dedicated runners including Apache Flink

Execute Apache Beam pipelines defined in YAML on Direct, Flink, Spark, or Dataflow runners while forwarding Beam metrics to Kestra.

tasks

RunPipeline
io.kestra.plugin.beam.RunPipeline

More Plugins in this Category

MongoDB
MongoDB

Tasks that query and manipulate MongoDB collections.

Data

8 Tasks

3 Blueprints

Weaviate
Weaviate

Tasks that manage and query vectors in Weaviate.

DataAI

4 Tasks

2 Blueprints

Grok
Grok

Kestra Plugin Transformation for Grok.

Data

2 Tasks
OVERVIEW
Versions
1.0.2
Latest
February 16, 2026 Release Notes Min. Compatible Kestra Version: 1.2.3
Previous Versions
1.0.1January 16, 2026 Min. Compatible Kestra Version: 1.0.0
1.0.0January 14, 2026 Min. Compatible Kestra Version: 1.0.0

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Data
Links & Resources
GitHub