Submit

Submit

Certified

Submit Flink job from JAR over REST

yaml
type: io.kestra.plugin.flink.Submit
yaml
id: flink-batch-job
namespace: company.team

tasks:
  - id: submit-job
    type: io.kestra.plugin.flink.Submit
    restUrl: "http://flink-jobmanager:8081"
    jarUri: "s3://flink/jars/my-batch-job.jar"
    entryClass: "com.example.BatchJobMain"
    args:
      - "--input"
      - "s3://input/data/"
      - "--output"
      - "s3://output/results/"
    parallelism: 4
Properties
Defaultfalse
SubTypestring

More Plugins in this Category

MongoDB
MongoDB

Tasks that query and manipulate MongoDB collections.

Data

8 tasks

3 blueprints

Transform
Transform

Transform typed records, variables, and Ion data.

CoreData

6 tasks