I'm trying out Flink Per-Job deployment using docker-compose.

Configurations:

version: "2.2"
jobs:
  jobmanager:
    build: ./
    image: flink_local:1.1
    ports:
      - "8081:8081"
    command: standalone-job --job-classname com.organization.BatchJob
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager
        parallelism.default: 2
  taskmanager:
    image: flink_local:1.1
    depends_on:
      - jobmanager
    command: taskmanager
    scale: 1
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager
        taskmanager.numberOfTaskSlots: 2
        parallelism.default: 2

Flink image is extended with job.jar, Job executed successfully.

JobManager exited after the job is completed, but is still running, which
is not expected.

Any configurations have to be added to exit both JobManager and TaskManger?

Versions:

Flink - 1.11.0

Java - 1.8

-- 
A.Narasimha Swamy

Reply via email to