YARN-1723. AMRMClientAsync missing blacklist addition and removal functionality. Contributed by Bartosz Åugowski.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/fe770f6a Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/fe770f6a Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/fe770f6a Branch: refs/heads/HDFS-EC Commit: fe770f6a28b811e2d01d386dae8f59c44e7c5277 Parents: 0809cb7 Author: Siddharth Seth <[email protected]> Authored: Wed Feb 4 12:52:02 2015 -0800 Committer: Zhe Zhang <[email protected]> Committed: Fri Feb 6 13:45:47 2015 -0800 ---------------------------------------------------------------------- hadoop-yarn-project/CHANGES.txt | 3 +++ .../hadoop/yarn/client/api/async/AMRMClientAsync.java | 11 +++++++++++ .../client/api/async/impl/AMRMClientAsyncImpl.java | 13 +++++++++++++ 3 files changed, 27 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/fe770f6a/hadoop-yarn-project/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index cb12eb9..1d6f2b4 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -239,6 +239,9 @@ Release 2.7.0 - UNRELEASED YARN-1393. SLS: Add how-to-use instructions. (Wei Yan via kasha) + YARN-1723. AMRMClientAsync missing blacklist addition and removal + functionality. (Bartosz Åugowski via sseth) + OPTIMIZATIONS BUG FIXES http://git-wip-us.apache.org/repos/asf/hadoop/blob/fe770f6a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/AMRMClientAsync.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/AMRMClientAsync.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/AMRMClientAsync.java index af26da1..f62e71b 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/AMRMClientAsync.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/AMRMClientAsync.java @@ -195,6 +195,17 @@ extends AbstractService { public abstract int getClusterNodeCount(); /** + * Update application's blacklist with addition or removal resources. + * + * @param blacklistAdditions list of resources which should be added to the + * application blacklist + * @param blacklistRemovals list of resources which should be removed from the + * application blacklist + */ + public abstract void updateBlacklist(List<String> blacklistAdditions, + List<String> blacklistRemovals); + + /** * Wait for <code>check</code> to return true for each 1000 ms. * See also {@link #waitFor(com.google.common.base.Supplier, int)} * and {@link #waitFor(com.google.common.base.Supplier, int, int)} http://git-wip-us.apache.org/repos/asf/hadoop/blob/fe770f6a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java index 82768bb..addc3b6 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/async/impl/AMRMClientAsyncImpl.java @@ -205,6 +205,19 @@ extends AMRMClientAsync<T> { public int getClusterNodeCount() { return client.getClusterNodeCount(); } + + /** + * Update application's blacklist with addition or removal resources. + * + * @param blacklistAdditions list of resources which should be added to the + * application blacklist + * @param blacklistRemovals list of resources which should be removed from the + * application blacklist + */ + public void updateBlacklist(List<String> blacklistAdditions, + List<String> blacklistRemovals) { + client.updateBlacklist(blacklistAdditions, blacklistRemovals); + } private class HeartbeatThread extends Thread { public HeartbeatThread() {
