| commit | dcd99d13414c900d8e5f86e3f62ed7567d6edd68 | [log] [tgz] |
|---|---|---|
| author | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Thu Oct 06 06:47:04 2011 +0000 |
| committer | vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053> | Thu Oct 06 06:47:04 2011 +0000 |
| tree | 33c195a5b0f9e1c358f3a42d25db49c05836e170 | |
| parent | 1c2370e4a4838aebb5c419072a9328a900d055bb [diff] |
Added notification for stagelets aborted before all operators are started git-svn-id: https://hyracks.googlecode.com/svn/trunk@600 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Stagelet.java b/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Stagelet.java index f1cb62e..a838f55 100644 --- a/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Stagelet.java +++ b/hyracks/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Stagelet.java
@@ -109,6 +109,7 @@ public synchronized void abort() { this.abort = true; + notifyAll(); for (OperatorRunnable r : honMap.values()) { r.abort(); }