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 we...@apache.org on 2019/06/22 01:28:58 UTC
[hadoop] branch trunk updated: HDFS-14074. DataNode runs async disk
checks maybe throws NullPointerException,
and DataNode failed to register to NameSpace. Contributed by guangyi lu.
This is an automated email from the ASF dual-hosted git repository.
weichiu pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 645d67b HDFS-14074. DataNode runs async disk checks maybe throws NullPointerException, and DataNode failed to register to NameSpace. Contributed by guangyi lu.
645d67b is described below
commit 645d67bc4f4e29d10ef810386c89e6a7c8c61862
Author: Wei-Chiu Chuang <we...@apache.org>
AuthorDate: Fri Jun 21 18:27:03 2019 -0700
HDFS-14074. DataNode runs async disk checks maybe throws NullPointerException, and DataNode failed to register to NameSpace. Contributed by guangyi lu.
---
.../hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 8844453..032379a 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
@@ -123,8 +123,8 @@ public class ThrottledAsyncChecker<K, V> implements AsyncChecker<K, V> {
return Optional.empty();
}
- if (completedChecks.containsKey(target)) {
- final LastCheckResult<V> result = completedChecks.get(target);
+ final LastCheckResult<V> result = completedChecks.get(target);
+ if (result != null) {
final long msSinceLastCheck = timer.monotonicNow() - result.completedAt;
if (msSinceLastCheck < minMsBetweenChecks) {
LOG.debug("Skipped checking {}. Time since last check {}ms " +
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org