(cherry picked from commit 5aa7052e319c3273243dda9993fb6c2d776eb7cc)
@@ -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);
+ }
}