I use this command to launch a flink yarn session.

yarn-session.sh -s 6 -jm 2048 -tm 4096 -nm sql-client-session -m
yarn-cluster -d

And all my flink sql job has 2 parallelism, and I found that my yarn
session can only have 3 pipelines. If my session doesn't have free slot,
submit to this session will cause exists pipeline failed. Can the yarn
session auto allocate new TM when it runs out its free slots?
-- 
Best regards

Sili Liu

Reply via email to