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;