[FLINK-23937][Documentation] Fix PQ comment in KeyGroupPartitionedPri…

…orityQueue (apache#16957)
nicusX · Dec 13, 2021 · a49a2b3 · a49a2b3
1 parent 47e6e89
commit a49a2b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java b/...e/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java
@@ -44,7 +44,7 @@
  * elements if the sub-queues have set semantics.
  *
  * @param <T> the type of elements in the queue.
- * @param <PQ> type type of sub-queue used for each key-group partition.
+ * @param <PQ> the type of sub-queue used for each key-group partition.
  */
 public class KeyGroupPartitionedPriorityQueue<
                 T, PQ extends InternalPriorityQueue<T> & HeapPriorityQueueElement>