commit | cf627ed38f63abfc13522d56e256d4e4bc3e3ec4 | [log] [tgz] |
---|---|---|
author | Young-Seok <kisskys@gmail.com> | Sun Sep 15 22:44:59 2013 -0700 |
committer | Young-Seok <kisskys@gmail.com> | Sun Sep 15 22:44:59 2013 -0700 |
tree | fafdf991e19a79edd621afa7d65a9a78ca8fccef | |
parent | dc7fba35f7897576fa9d2cfc264754fb8fbb1409 [diff] |
changes not to swallow an exception when there is failure during abort
diff --git a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Task.java b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Task.java index 09eeab6..c72ced1 100644 --- a/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Task.java +++ b/hyracks/hyracks-control/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Task.java
@@ -278,6 +278,9 @@ removePendingThread(ct); } if (!exceptions.isEmpty()) { + for (Exception e : exceptions) { + e.printStackTrace(); + } NodeControllerService ncs = joblet.getNodeController(); ExceptionUtils.setNodeIds(exceptions, ncs.getId()); ncs.getWorkQueue().schedule(new NotifyTaskFailureWork(ncs, this, exceptions));