Hi Srikanth, Is this issue what you encounter? FLINK-12122: a job would tend to fill one TM before using another. If it is, you may need to wait for the release 1.9.2 or 1.10, since it is just fixed.
Thanks, Zhu Zhu vino yang <yanghua1...@gmail.com> 于2019年11月11日周一 下午5:48写道： > Hi srikanth, > > What's your job's parallelism? > > In some scenes, many operators are chained with each other. if it's > parallelism is 1, it would just use a single slot. > > Best, > Vino > > srikanth flink <flink.d...@gmail.com> 于2019年11月6日周三 下午10:03写道： > >> Hi there, >> >> I'm running Flink with 3 node cluster. >> While running my jobs(both SQL client and jar submission), the jobs are >> being assigned to single machine instead of distribution among the cluster. >> How could I achieve the job distribution to make use of the computation >> power? >> >> Thanks >> Srikanth >> >
