@@ -166,7 +166,12 @@ public class LocalDirsHandlerService extends AbstractService {
@Override
public void run() {
- checkDirs();
+ try {
+ checkDirs();
+ } catch (Throwable t) {
+ // Prevent uncaught exceptions from killing this thread
+ LOG.warn("Error while checking local directories: ", t);
+ }
}