You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ss...@apache.org on 2015/02/04 21:52:37 UTC
hadoop git commit: YARN-1723. AMRMClientAsync missing blacklist addition and removal functionality. Contributed by Bartosz Ługowski.
Repository: hadoop
Updated Branches:
refs/heads/trunk 40a415799 -> e04e8fa81
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/e04e8fa8
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e04e8fa8
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e04e8fa8
Branch: refs/heads/trunk
Commit: e04e8fa8103fb58c2e449d78af6cbf5b552279f4
Parents: 40a4157
Author: Siddharth Seth <ss...@apache.org>
Authored: Wed Feb 4 12:52:02 2015 -0800
Committer: Siddharth Seth <ss...@apache.org>
Committed: Wed Feb 4 12:52:02 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/e04e8fa8/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/e04e8fa8/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/e04e8fa8/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() {