Thanks Piotrek for your response. Teena responsed for same. I am
implementing changes to try it out.
Yes, Originally I did call keyBy for same reason so that I can parallelize
the operation.
On Thu, Mar 1, 2018 at 1:24 AM, Piotr Nowojski
wrote:
> Hi,
>
> timeWindowAll is a non parallel operatio
Hi,
timeWindowAll is a non parallel operation, since it gathers all of the elements
and process them together:
https://ci.apache.org/projects/flink/flink-docs-release-1.4/api/java/org/apache/flink/streaming/api/datastream/DataStream.html#timeWindowAll-org.apache.flink.streaming.api.windowing.tim
