hi,all:

????????hadoop??????????????A.


????????A????????bin/yarn-session.sh -n 5 -jm 1g -tm 4g -s 4 -qu root.flink -nm 
fsql-cli > /dev/null 2>&1 &????????????????yarn-session??
????????????????root.flink????????fsql-cli.


????????yarn????????????????????????????????????????????????????????????????????????????????????????
https://imgchr.com/i/NJIn4x


??????????Flink session cluster
??????????root.default


??????????????????????????????????????????


flink??????1.10.0
flink-conf.yaml??????
[fsql@10-42-63-116 conf]$ grep -v ^# flink-conf.yaml |grep -v ^$
jobmanager.rpc.address: localhost
jobmanager.rpc.port: 6123
jobmanager.heap.size: 1024m
taskmanager.memory.process.size: 2048m
taskmanager.numberOfTaskSlots: 10
parallelism.default: 1
jobmanager.execution.failover-strategy: region

回复