Skip to content

Commit 1d44789

Browse files
authored
[refactor] Remove unnecessary implements for InternalPriorityQueue (#26315)
1 parent 034d19c commit 1d44789

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848
*/
4949
public class KeyGroupPartitionedPriorityQueue<
5050
T, PQ extends InternalPriorityQueue<T> & HeapPriorityQueueElement>
51-
implements InternalPriorityQueue<T>, KeyGroupedInternalPriorityQueue<T> {
51+
implements KeyGroupedInternalPriorityQueue<T> {
5252

5353
/** A heap of heap sets. Each sub-heap represents the partition for a key-group. */
5454
@Nonnull private final HeapPriorityQueue<PQ> heapOfKeyGroupedHeaps;

0 commit comments

Comments
 (0)