Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3783 Hi @huawei-flink , I'll close this PR later today when merging #5555. #5555 adds runtime support for distinct aggregation and follows a similar approach as this PR. However, it leverages the `MapView` feature and is therefore a bit more generic. Thanks for working on this. This PR led us in the right direction. Best, Fabian
---