百度云部署UAT环境的flink程序

#初始化，首次#创建网络

docker network create --driver=overlay --scope=swarm umi

1.swarm 打标签

docker node update --label-add flink-node=flink02 baidu-bj-bigdata-2

docker node update --label-add flink-node=flink03 baidu-bj-bigdata-3

2.创建目录

mkdir -p /data/flink/conf

3.配置文件conf

/data/flink/conf/config.yaml

blob: server: port: '6124'taskmanager: memory: process: size: 1728m bind-host: 0.0.0.0 numberOfTaskSlots: 8jobmanager: execution: failover-strategy: region rpc: address: flink-jobmanager port: 6123 memory: process: size: 1600m bind-host: 0.0.0.0high-availability: cluster-id: /cluster_umi mode: zookeeper zookeeper: path: root: /flink quorum: 10.10.0.11:2181 storageDir: /data/flinkquery: server: port: '6125'rest: bind-address: 0.0.0.0 port: 48081 address: 0.0.0.0parallelism: default: 1env: java: opts: all: --add-exports=java.base/sun.net.util=ALL-UNNAMED --add-exports=java.rmi/sun.rmi.registry=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-exports=java.security.jgss/sun.security.krb5=ALL-UNNAMED --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.io=ALL-UNNAMED --add-opens=java.base/java.nio=ALL-UNNAMED --add-opens=java.base/sun.nio.ch=ALL-UNNAMED --add-opens=java.base/java.lang.reflect=ALL-UNNAMED --add-opens=java.base/java.text=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED