Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Implemented
-
0.11.2
-
None
Description
Add a method - countElementsPerPartition() that returns a Tuple2<PartitionID, PartitionCount>, this is a temporary fix until the PR for Flink-3657 is merged into Flink Codebase.