-spread-out-slots
configuration [1].
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/config.html#cluster-evenly-spread-out-slots
On Mon, Sep 14, 2020 at 5:33 PM Arti Pande wrote:
> Hi,
>
> Here is a question related to parallelism of keyed-process-function
Hi,
Here is a question related to parallelism of keyed-process-function that is
applied to the KeyedStream. For some code that looks like this
myStream.keyBy(...)
.process(new MyKeyedProcessFunction())
.process().setParallelism(10)
On a Flink cluster with 5 TM nodes each with 10 task
