|
@@ -3894,14 +3894,17 @@ public class FSNamesystem implements Namesystem, FSNamesystemMBean,
|
|
.debug("Namenode is in safemode, skipping scrubbing of corrupted lazy-persist files.");
|
|
.debug("Namenode is in safemode, skipping scrubbing of corrupted lazy-persist files.");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ FSNamesystem.LOG.error(
|
|
|
|
+ "Ignoring exception in LazyPersistFileScrubber:", e);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ try {
|
|
Thread.sleep(scrubIntervalSec * 1000);
|
|
Thread.sleep(scrubIntervalSec * 1000);
|
|
} catch (InterruptedException e) {
|
|
} catch (InterruptedException e) {
|
|
FSNamesystem.LOG.info(
|
|
FSNamesystem.LOG.info(
|
|
"LazyPersistFileScrubber was interrupted, exiting");
|
|
"LazyPersistFileScrubber was interrupted, exiting");
|
|
break;
|
|
break;
|
|
- } catch (Exception e) {
|
|
|
|
- FSNamesystem.LOG.error(
|
|
|
|
- "Ignoring exception in LazyPersistFileScrubber:", e);
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|