[hotfix][coordination] Update field name
PartitionTable was at some point only tracking per job but was later generalized to work with arbitrary keys. The field name was updated accordingly however.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/PartitionTable.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/PartitionTable.java
index d214e09..ac032dd 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/PartitionTable.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/PartitionTable.java
@@ -35,13 +35,13 @@
@ThreadSafe
public class PartitionTable<K> {
- private final Map<K, Set<ResultPartitionID>> trackedPartitionsPerJob = new ConcurrentHashMap<>(8);
+ private final Map<K, Set<ResultPartitionID>> trackedPartitionsPerKey = new ConcurrentHashMap<>(8);
/**
* Returns whether any partitions are being tracked for the given key.
*/
public boolean hasTrackedPartitions(K key) {
- return trackedPartitionsPerJob.containsKey(key);
+ return trackedPartitionsPerKey.containsKey(key);
}
/**
@@ -55,7 +55,7 @@
return;
}
- trackedPartitionsPerJob.compute(key, (ignored, partitionIds) -> {
+ trackedPartitionsPerKey.compute(key, (ignored, partitionIds) -> {
if (partitionIds == null) {
partitionIds = new HashSet<>(8);
}
@@ -70,7 +70,7 @@
public Collection<ResultPartitionID> stopTrackingPartitions(K key) {
Preconditions.checkNotNull(key);
- Set<ResultPartitionID> storedPartitions = trackedPartitionsPerJob.remove(key);
+ Set<ResultPartitionID> storedPartitions = trackedPartitionsPerKey.remove(key);
return storedPartitions == null
? Collections.emptyList()
: storedPartitions;
@@ -84,7 +84,7 @@
Preconditions.checkNotNull(partitionIds);
// If the key is unknown we do not fail here, in line with ShuffleEnvironment#releaseFinishedPartitions
- trackedPartitionsPerJob.computeIfPresent(
+ trackedPartitionsPerKey.computeIfPresent(
key,
(ignored, resultPartitionIDS) -> {
resultPartitionIDS.removeAll(partitionIds);
