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 ha...@apache.org on 2018/01/31 19:05:37 UTC
hadoop git commit: HDFS-13092. Reduce verbosity for
ThrottledAsyncChecker#schedule. Contributed by Mukul Kumar Singh.
Repository: hadoop
Updated Branches:
refs/heads/trunk 37b753656 -> 3ce2190b5
HDFS-13092. Reduce verbosity for ThrottledAsyncChecker#schedule. Contributed by Mukul Kumar Singh.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/3ce2190b
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/3ce2190b
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/3ce2190b
Branch: refs/heads/trunk
Commit: 3ce2190b581526ad2d49e8c3a47be1547037310c
Parents: 37b7536
Author: Hanisha Koneru <ha...@apache.org>
Authored: Wed Jan 31 11:05:17 2018 -0800
Committer: Hanisha Koneru <ha...@apache.org>
Committed: Wed Jan 31 11:05:17 2018 -0800
----------------------------------------------------------------------
.../hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/3ce2190b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java
index b71c015..9227d94 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java
@@ -119,7 +119,6 @@ public class ThrottledAsyncChecker<K, V> implements AsyncChecker<K, V> {
@Override
public Optional<ListenableFuture<V>> schedule(Checkable<K, V> target,
K context) {
- LOG.info("Scheduling a check for {}", target);
if (checksInProgress.containsKey(target)) {
return Optional.absent();
}
@@ -135,6 +134,7 @@ public class ThrottledAsyncChecker<K, V> implements AsyncChecker<K, V> {
}
}
+ LOG.info("Scheduling a check for {}", target);
final ListenableFuture<V> lfWithoutTimeout = executorService.submit(
new Callable<V>() {
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org