From the article below we know the parallelism is 1 for non-keyed streams, so can we increase the parallelism by setParallelism ? "In case of non-keyed streams, your original stream will not be split into multiple logical streams and all the windowing logic will be performed by a single task, i.e. with parallelism of 1."
3
votes
1 Answers
-1
votes
As soon as you would try to use setParallelism to set a different value than 1 on an operator of a stream within an All Window operator, an exception will be thrown. This functionality is also exposed, as you can use forceNonParallel to ensure that the parallelism of the corresponding operator cannot be overridden.
