Raman Yelianevich

@ballooncross Looking at your code I can suggest an alternative approach by using a custom global combiner that will eliminate subsequent `Latest.globally()` and `View.asSingleton()` and will do everything in one...

Hi @IvanFroehlich. Have you tried the solution I posted [above](https://github.com/apache/beam/issues/26465#issuecomment-1929855207)?

Hi, I'm facing a similar issue with Beam 2.56.0 and Flink 1.16.3 and Java SDK. The problematic pipeline has parallelism 4 and has many *slowly updating global window side inputs*...

@je-ik thanks for a quick response! What I ment is that only when all subtasks of the source emit a record (see 'Records sent' in the image below) then I...

Thanks, I'll create a separate issue. What do you think about the issue with KafkaIO? The topic has 3 partitions. As you can see from the screenshot below it received...

@je-ik Do you have any suggestions how to workaround the issue when there are several idle Kafka partitions/topics in the topology that hold an overall progress? It used to work...

I tested various versions of Apache Beam with Apache Flink 1.15.4 and the issue started to appear in 2.52.0. Apache Beam 2.46.0 - 2.51.0 does not have this issue with...

> I don't know if there are any workarounds, as the described behavior seems to be (unknown) bug. It needs further investigation. Could you please provide a simplified pipeline that...

@je-ik I do not specify any additional flags in the test, so I think it uses defaults. I run the same test using `--experiments=use_deprecated_read` and it didn't change anything. The...