[hotfix] Rename BufferManager#unsynchronizedGetExclusiveBuffersUsed t…

…o BufferManager#unsynchronizedGetAvailableExclusiveBuffers This closes apache#12994.
deepfield · Aug 13, 2020 · 0fbe7a2 · 0fbe7a2
1 parent 1ff1266
commit 0fbe7a2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...e/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java b/...e/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java
@@ -327,7 +327,7 @@ int getNumberOfAvailableBuffers() {
  }
  }
 
- int unsynchronizedGetExclusiveBuffersUsed() {
+ int unsynchronizedGetAvailableExclusiveBuffers() {
  return bufferQueue.exclusiveBuffers.size();
  }
 

diff --git a/.../main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java b/.../main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
@@ -381,7 +381,7 @@ public int unsynchronizedGetNumberOfQueuedBuffers() {
  }
 
  public int unsynchronizedGetExclusiveBuffersUsed() {
- return Math.max(0, initialCredit - bufferManager.unsynchronizedGetExclusiveBuffersUsed());
+ return Math.max(0, initialCredit - bufferManager.unsynchronizedGetAvailableExclusiveBuffers());
  }
 
  public int unsynchronizedGetFloatingBuffersAvailable() {