flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: How flink assigns task slots to the streams of the same app?
Date Mon, 18 Dec 2017 14:46:27 GMT
Hi Jinhua,

you need to set a higher parallelism to your application when submitting 
your application. You can also set it via env.setParallelism() or even 
on an operator level map.setParallelism().

The number of task slots must be greater or equals to the parallelism of 
your application, otherwise the submission fails.

I hope that helps.


Am 12/18/17 um 2:11 PM schrieb Jinhua Luo:
> Hi All,
> I start an app which contains multiple streams, and I found some
> stream of them get processed very slow, which uses keyBy() and the
> number of key would be up to million, and I also found all streams
> share only one task slot. Is it possible to assign more slots to the
> app?

View raw message