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() {