From 5fe2925203a06f2eabb7e37f1e6906214885fe63 Mon Sep 17 00:00:00 2001 From: Gang Liao Date: Thu, 26 Sep 2019 19:35:49 -0400 Subject: [PATCH] change to MICROSECONDS --- .../apache/hadoop/hdfs/server/namenode/INodeKeyedObjects.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/namenode/INodeKeyedObjects.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeKeyedObjects.java index d2020e6d373..25886e466f9 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeKeyedObjects.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/INodeKeyedObjects.java @@ -44,7 +44,7 @@ public static void BackupSetToDB() { public void run() { int i = 0; final int num = 1024; - if (concurrentHashSet.size() >= num) { + if (concurrentHashSet.size() > 0) { Iterator iterator = concurrentHashSet.iterator(); if (LOG.isInfoEnabled()) { LOG.info("Sync files/directories from cache to database."); @@ -99,7 +99,7 @@ public void run() { } final ScheduledFuture updateHandle = - scheduler.scheduleWithFixedDelay(updateToDB, 100, delay, MILLISECONDS); + scheduler.scheduleWithFixedDelay(updateToDB, 100, delay, MICROSECONDS); scheduler.schedule( new Runnable() {