Github user makeyang commented on the issue: https://github.com/apache/flink/pull/5908 @StefanRRichter I definitely like u ideas about flat copy priority queue in sync and then handler key-group thing in async. so I'll get rid of my solution and try to implement u solution and then give it a new pr
---