[hotfix][yarn] Remove unused function in YarnResourceManagerDriver

This closes apache#13683.
lightClouds917 · Oct 20, 2020 · 9b612a0 · 9b612a0
1 parent 2a64773
commit 9b612a0
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java
@@ -317,10 +317,6 @@ private int getNumRequestedNotAllocatedWorkers() {
 		return requestResourceFutures.values().stream().mapToInt(Queue::size).sum();
 	}
 
-	private int getNumRequestedNotAllocatedWorkersFor(TaskExecutorProcessSpec taskExecutorProcessSpec) {
-		return requestResourceFutures.getOrDefault(taskExecutorProcessSpec, new LinkedList<>()).size();
-	}
-
 	private void removeContainerRequest(AMRMClient.ContainerRequest pendingContainerRequest) {
 		log.info("Removing container request {}.", pendingContainerRequest);
 		resourceManagerClient.removeContainerRequest(pendingContainerRequest);