|
@@ -37,6 +37,8 @@ import java.util.concurrent.ScheduledThreadPoolExecutor;
|
|
|
import java.util.concurrent.ThreadLocalRandom;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
import java.util.concurrent.atomic.AtomicLong;
|
|
|
+
|
|
|
+import org.apache.commons.lang.time.FastDateFormat;
|
|
|
import org.apache.commons.logging.Log;
|
|
|
import org.apache.commons.logging.LogFactory;
|
|
|
import org.apache.hadoop.classification.InterfaceAudience;
|
|
@@ -61,7 +63,7 @@ public class DirectoryScanner implements Runnable {
|
|
|
private static final int MILLIS_PER_SECOND = 1000;
|
|
|
private static final String START_MESSAGE =
|
|
|
"Periodic Directory Tree Verification scan"
|
|
|
- + " starting at %dms with interval of %dms";
|
|
|
+ + " starting at %s with interval of %dms";
|
|
|
private static final String START_MESSAGE_WITH_THROTTLE = START_MESSAGE
|
|
|
+ " and throttle limit of %dms/s";
|
|
|
|
|
@@ -268,10 +270,12 @@ public class DirectoryScanner implements Runnable {
|
|
|
String logMsg;
|
|
|
|
|
|
if (throttleLimitMsPerSec < MILLIS_PER_SECOND) {
|
|
|
- logMsg = String.format(START_MESSAGE_WITH_THROTTLE, firstScanTime,
|
|
|
- scanPeriodMsecs, throttleLimitMsPerSec);
|
|
|
+ logMsg = String.format(START_MESSAGE_WITH_THROTTLE,
|
|
|
+ FastDateFormat.getInstance().format(firstScanTime), scanPeriodMsecs,
|
|
|
+ throttleLimitMsPerSec);
|
|
|
} else {
|
|
|
- logMsg = String.format(START_MESSAGE, firstScanTime, scanPeriodMsecs);
|
|
|
+ logMsg = String.format(START_MESSAGE,
|
|
|
+ FastDateFormat.getInstance().format(firstScanTime), scanPeriodMsecs);
|
|
|
}
|
|
|
|
|
|
LOG.info(logMsg);
|