Re: job doesn't start via cli after migrating Flink from 1.8 to 1.10

2020-04-10 Thread Yang Wang
I am trying to answer your question inline. > The server has twice more than that, and on flink 1.8 this configuration > works, why when switching to 1.10 it is not enough resources? >From 1.10, the taskmanager resource related configuration has changed and the default value is bigger than befo

job doesn't start via cli after migrating Flink from 1.8 to 1.10

2020-04-08 Thread Vitaliy Semochkin
Hi, I've recently migrated from Flink 1.8 to Flink 1.10 And when I start the job using YarnClusterDescriptor.deployJobCluster method everything works fine. However when I start the job from shell script, the job fails with messages: *Shell script reports:* Cluster specification: ClusterSpecificat