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 yq...@apache.org on 2017/02/06 05:15:56 UTC
hadoop git commit: HDFS-11377. Balancer hung due to no available
mover threads. Contributed by yunjiong zhao.
Repository: hadoop
Updated Branches:
refs/heads/trunk cce35c381 -> 9cbbd1eae
HDFS-11377. Balancer hung due to no available mover threads. Contributed by yunjiong zhao.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/9cbbd1ea
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/9cbbd1ea
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/9cbbd1ea
Branch: refs/heads/trunk
Commit: 9cbbd1eae893b21212c9bc9e6745c6859317a667
Parents: cce35c3
Author: Yiqun Lin <yq...@apache.org>
Authored: Mon Feb 6 13:15:16 2017 +0800
Committer: Yiqun Lin <yq...@apache.org>
Committed: Mon Feb 6 13:15:16 2017 +0800
----------------------------------------------------------------------
.../java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/9cbbd1ea/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java
index 6b153da..ceccff5 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/Dispatcher.java
@@ -88,7 +88,6 @@ import com.google.common.base.Preconditions;
public class Dispatcher {
static final Log LOG = LogFactory.getLog(Dispatcher.class);
- private static final int MAX_NO_PENDING_MOVE_ITERATIONS = 5;
/**
* the period of time to delay the usage of a DataNode after hitting
* errors when using it for migrating data
@@ -1108,6 +1107,8 @@ public class Dispatcher {
}
if (moveExecutor == null) {
LOG.warn("No mover threads available: skip moving " + p);
+ targetDn.removePendingBlock(p);
+ p.proxySource.removePendingBlock(p);
return;
}
moveExecutor.execute(new Runnable() {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org