commit bf67b0363eb273a919713c8e8f5c326ee04b3b5e
author vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Wed Sep 28 02:23:29 2011 +0000
committer vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> Wed Sep 28 02:23:29 2011 +0000
tree b0902b472cca8e12e4f6ca91ac2e64f25b7c175c
parent 7e2a9c8def2cdc581031189bf2017c1207badc48

Added calling of listener on job failure

git-svn-id: https://hyracks.googlecode.com/svn/trunk@581 123451ca-8445-de46-9d55-352943316053

hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/NodeControllerService.java

diff --git a/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/NodeControllerService.java b/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/NodeControllerService.java
index 163d792..25bf741 100644
--- a/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/NodeControllerService.java
+++ b/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/NodeControllerService.java
@@ -582,7 +582,11 @@
         Joblet ji = jobletMap.get(jobId);
         if (ji != null) {
             if (ji.getAttempt() == attempt) {
-                jobletMap.remove(jobId);
+                Joblet joblet = jobletMap.remove(jobId);
+                IJobletEventListener listener = joblet.getJobletEventListener();
+                if (listener != null) {
+                    listener.jobletFinish(false);
+                }
             }
             for (Stagelet stagelet : ji.getStageletMap().values()) {
                 stagelet.abort();