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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
