Re: Understanding blocking behavior

2021-02-16 Thread Arvid Heise
s [Engineering]" > *Date: *Tuesday, February 16, 2021 at 2:00 PM > *To: *"user@flink.apache.org" > *Subject: *Understanding blocking behavior > > > > Hi folks, I’m trying to get a better understanding of what operations > result in blocked partitions. I’ve got a bat

Re: Understanding blocking behavior

2021-02-16 Thread Jaffe, Julian
pipeline in streaming mode over bounded data. Julian From: "Hailu, Andreas [Engineering]" Date: Tuesday, February 16, 2021 at 2:00 PM To: "user@flink.apache.org" Subject: Understanding blocking behavior Hi folks, I’m trying to get a better understanding of what operation

Understanding blocking behavior

2021-02-16 Thread Hailu, Andreas [Engineering]
Hi folks, I'm trying to get a better understanding of what operations result in blocked partitions. I've got a batch-processing job that reads from 2 sources, and then performs a series of Maps/Filters/CoGroups all with the same parallelism to create a final DataSet to be written to two differen