Re: problem scale Flink job on YARN

2017-10-19 Thread Lei Chen
Hi Aljoscha, I'm using version 1.3.0 and changing job-wide parallelism. Lei On Thu, Oct 19, 2017 at 9:47 AM, Aljoscha Krettek wrote: > Hi Lei, > > Which version of Flink would that be? I'm guessing >= 1.3.x? In Flink 1.1 > the hash of an operator was tied to the parallelism but starting with 1

Re: problem scale Flink job on YARN

2017-10-19 Thread Aljoscha Krettek
Hi Lei, Which version of Flink would that be? I'm guessing >= 1.3.x? In Flink 1.1 the hash of an operator was tied to the parallelism but starting with 1.2 that shouldn't happen anymore. Also, are you changing the parallelism job-wide or are there operators with differing parallelism? For exam