Flink Deploy

Cluster

Starting a Session Cluster on Docker

# https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/resource-providers/standalone/docker/#starting-a-session-cluster-on-docker

FLINK_PROPERTIES="jobmanager.rpc.address: flink-jobmanager"
docker network create flink

# launch the JobManager
docker run -d \
    --name=flink-jobmanager \
    --network flink \
    --publish 8081:8081 \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    flink jobmanager
    
# one or more TaskManager containers    
docker run -d \
    --name=flink-taskmanager1 \
    --network flink \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    flink taskmanager
    
# submit a task    
./bin/flink run ./examples/streaming/TopSpeedWindowing.jar    
最后修改 2023-03-11: split into more parts (54b443e)