Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-14074. DataNode runs async disk checks maybe throws NullPointerException, and DataNode failed to register to NameSpace. Contributed by guangyi lu. 

(cherry picked from commit 645d67bc4f)
This commit is contained in:
Wei-Chiu Chuang 2019-06-21 18:27:03 -07:00
parent 845d7611ba
commit d5ecca1d4c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/checker/ThrottledAsyncChecker.java
View File

@ -123,8 +123,8 @@ public class ThrottledAsyncChecker<K, V> implements AsyncChecker<K, V> {
return Optional.empty(); 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; final long msSinceLastCheck = timer.monotonicNow() - result.completedAt;
if (msSinceLastCheck < minMsBetweenChecks) { if (msSinceLastCheck < minMsBetweenChecks) {
LOG.debug("Skipped checking {}. Time since last check {}ms " + LOG.debug("Skipped checking {}. Time since last check {}ms " +