服务器: 220.243.137.100 执行时间: 20230514 参考: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/overview/ 目录: /data/soft/flink/local-flink/flink-1.17.0 以Application Model的方式进行启动 https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/overview/#application-mode 应用jar放在: /data/soft/flink/local-flink/jars/ cd /data/soft/flink/local-flink/flink-1.17.0 cp /data/soft/flink/local-flink/flink-1.17.0/tenant-data-etc-task-v1.0.0.jar lib/ cp /data/soft/flink/local-flink/flink-1.17.0/flink-cdc-kafka-source-task-v1.0.0.jar lib/ cd /data/soft/flink/local-flink/flink-1.17.0 ./bin/standalone-job.sh start --job-classname com.bcxin.flink.cdc.kafka.source.task.JdbcBinLogCaptureApp te 370 ./bin/standalone-job.sh start --job-classname com.bcxin.tenant.data.etc.tasks.DataEtcApp --env test2 --configFile company ./bin/standalone-job.sh start --job-classname com.bcxin.tenant.data.etc.tasks.DataEtcApp --env test2 --configFile others ./bin/standalone-job.sh start --job-classname com.bcxin.tenant.data.etc.tasks.DataEtcApp --env test2 --configFile user 此时; 只是Web可用, 但是应用程序还不会启动,因为我们还没有启动taskmanagers, 因此需要 ./bin/taskmanager.sh start ./bin/taskmanager.sh stop ./bin/standalone-job.sh stop ./bin/standalone-job.sh start -D jobmanager.rpc.address=localhost -D rest.bind-address=0.0.0.0 -D rest.bind-port=8082 -D rest.port=8082 --job-classname com.bcxin.tenant.data.etc.tasks.DataEtcApp --env test2 --configFile company ./bin/standalone-job.sh start --job-classname com.bcxin.tenant.data.etc.tasks.DataEtcApp --env test2 --configFile company ./bin/jobmanager.sh start -D jobmanager.rpc.address=localhost -D rest.port=8082