You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2019/09/19 12:05:24 UTC

[flink] 05/07: [FLINK-13796][coordination] Remove unused variable from YarnResourceManager

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit d98132f4e286296a87ab3ae879ca09eb98165c27
Author: Fokko Driesprong <fo...@apache.org>
AuthorDate: Tue Aug 20 13:35:21 2019 +0200

    [FLINK-13796][coordination] Remove unused variable from YarnResourceManager
    
    This closes #9492
---
 .../src/main/java/org/apache/flink/yarn/YarnResourceManager.java       | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
index c7cb064..2e1f62b 100755
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java
@@ -68,7 +68,6 @@ import java.net.URL;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
-import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
@@ -125,8 +124,6 @@ public class YarnResourceManager extends ResourceManager<YarnWorkerNode> impleme
 	/** The number of containers requested, but not yet granted. */
 	private int numPendingContainerRequests;
 
-	private final Map<ResourceProfile, Integer> resourcePriorities = new HashMap<>();
-
 	private final Collection<ResourceProfile> slotsPerWorker;
 
 	private final Resource resource;