|
@@ -37,8 +37,6 @@ 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;
|
|
@@ -63,7 +61,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 %s with interval of %dms";
|
|
|
+ + " starting at %dms with interval of %dms";
|
|
|
private static final String START_MESSAGE_WITH_THROTTLE = START_MESSAGE
|
|
|
+ " and throttle limit of %dms/s";
|
|
|
|
|
@@ -270,12 +268,10 @@ public class DirectoryScanner implements Runnable {
|
|
|
String logMsg;
|
|
|
|
|
|
if (throttleLimitMsPerSec < MILLIS_PER_SECOND) {
|
|
|
- logMsg = String.format(START_MESSAGE_WITH_THROTTLE,
|
|
|
- FastDateFormat.getInstance().format(firstScanTime), scanPeriodMsecs,
|
|
|
- throttleLimitMsPerSec);
|
|
|
+ logMsg = String.format(START_MESSAGE_WITH_THROTTLE, firstScanTime,
|
|
|
+ scanPeriodMsecs, throttleLimitMsPerSec);
|
|
|
} else {
|
|
|
- logMsg = String.format(START_MESSAGE,
|
|
|
- FastDateFormat.getInstance().format(firstScanTime), scanPeriodMsecs);
|
|
|
+ logMsg = String.format(START_MESSAGE, firstScanTime, scanPeriodMsecs);
|
|
|
}
|
|
|
|
|
|
LOG.info(logMsg);
|