| commit | fb7ec921374d2b81cc73a038c0b601bc7cc575c5 | [log] [tgz] |
|---|---|---|
| author | Jake Biesinger <jake.biesinger@gmail.com> | Sat Aug 31 23:50:39 2013 -0700 |
| committer | Jake Biesinger <jake.biesinger@gmail.com> | Sat Aug 31 23:52:14 2013 -0700 |
| tree | 274490edacbf6e2681f9884058c96919dc6f22d7 | |
| parent | 12289d059f92d0116387a82098dddbcda21e8b9e [diff] |
shut down ResultStateSweeper when it's interrupted
diff --git a/hyracks/hyracks-control/hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/dataset/ResultStateSweeper.java b/hyracks/hyracks-control/hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/dataset/ResultStateSweeper.java index 69b560c..5a6d849 100644 --- a/hyracks/hyracks-control/hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/dataset/ResultStateSweeper.java +++ b/hyracks/hyracks-control/hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/dataset/ResultStateSweeper.java
@@ -55,6 +55,7 @@ } catch (InterruptedException e) { LOGGER.severe("Result cleaner thread interrupted, but we continue running it."); // There isn't much we can do really here + break; // the interrupt was explicit from another thread. This thread should shut down... } }