Original src from apache/flink-docker and version 1.13.2

• To update new-est dockerfile for new release apache flink access this repo apache/flink-docker then choose your verison

• If arm64 type host machine, Just change the base image of Dockerfile from openjdk:11-jre for x64 ---> arm64v8/openjdk:11-jre-buster to support arm64 build

• change maybe_enable_jemalloc function from docker-entrypint.sh to use jemalloc on arm64 cpu :

maybe_enable_jemalloc() {
    if [ "${DISABLE_JEMALLOC:-false}" == "false" ]; then
        
        if [ "$(uname -m)" == "aarch64" ]; then
            echo "load libjemalloc for arm64v8 arch "
            export LD_PRELOAD=$LD_PRELOAD:/usr/lib/aarch64-linux-gnu/libjemalloc.so
        else
            echo "load libjemalloc for x86/64 arch "
            export LD_PRELOAD=$LD_PRELOAD:/usr/lib/x86_64-linux-gnu/libjemalloc.so
        fi   
    fi
}

• To Build image : docker-compose -f ./docker-compose-build.yml build

• To start java flink cluster : docker-compose -f ./docker-compose.yml up -d

  • 1 x jobmanager
  • 2 x taskmanager ( taskmanager1 and taskmanager2)
  • each taskmanager have 2 slot ==> total slot = 2taskmanager x 2slot = 4 slot
  • vist http://your_flink_ip:8081/ to view the cluster status and deploy you new job

• Reference link

  • flink docker setup