|
@@ -229,9 +229,12 @@ class ReduceTask extends Task {
|
|
reportProgress(umbilical);
|
|
reportProgress(umbilical);
|
|
Thread.sleep(PROGRESS_INTERVAL);
|
|
Thread.sleep(PROGRESS_INTERVAL);
|
|
} catch (InterruptedException e) {
|
|
} catch (InterruptedException e) {
|
|
- continue;
|
|
|
|
|
|
+ return;
|
|
} catch (Throwable e) {
|
|
} catch (Throwable e) {
|
|
- return;
|
|
|
|
|
|
+ System.out.println("Thread Exception in " +
|
|
|
|
+ "reporting sort progress\n" +
|
|
|
|
+ StringUtils.stringifyException(e));
|
|
|
|
+ continue;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|