服务器: 220.243.137.100
执行时间: 20230514
参考: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/overview/
服务器: test-rt

【针对java版本不一致的情况-参考】
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/config/#configuration
比如: OS 默认是安装java17, 但是我运行需要使用java 8
通过在./conf/flink-conf.yaml中设置env.java.home参数可以设置java的安装根目录
单单修改上面好像还是不行，后面我也修改了
export JAVA_HOME=/usr/local/java/

并在flink-conf.yaml中配置taskmanager.memory.task.off-heap.size: 256mb

设置env.java.opts:-Xmx 6144m -Xms 2048m

【配置】
https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz

目录: /data/soft/flink/flink-1.16.1
以Session Model的方式进行启动
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/overview/#starting-a-standalone-cluster-session-mode
应用jar放在: /data/soft/flink/flink-1.17.0/jars/


cd /data/soft/flink/flink-1.16.1

./bin/start-cluster.sh
nohup ./bin/flink run ../jars/tenant-data-etc-task-v2.0.jar test2 user > flink-user.log&
nohup ./bin/flink run ../jars/tenant-data-etc-task-v2.0.jar test2 company > flink-company.log&
nohup ./bin/flink run ../jars/tenant-data-etc-task-v2.0.jar test2 others > flink-others.log&
nohup ./bin/flink run ../jars/flink-cdc-kafka-source-task-v2.0.jar te 370 > flink-cdc-kafka-source-task-te-370.log&


./bin/stop-cluster.sh

/data/soft/flink/flink-1.16.1