Hi Singh, All the output operator transformed by AllWindowedStream would be SingleOutputStreamOperator, which cannot be parallel.
[1] https://github.com/apache/flink/blob/master/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala Best Yun Tang ________________________________ From: M Singh <mans2si...@yahoo.com> Sent: Sunday, January 23, 2022 4:24 To: User-Flink <user@flink.apache.org> Subject: Apache Flink - Can AllWindowedStream be parallel ? Hi Folks: The documentation for AllWindowedStream (https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/overview/#datastream-rarr-allwindowedstream) has a note: This is in many cases a non-parallel transformation. All records will be gathered in one task for the windowAll operator. Does this mean that in some cases it might be parallel ? If so, is there an example of such a scenario ? Thanks
