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