This commit is contained in:
Gianpaolo Coro 2012-05-24 12:41:46 +00:00
parent a02f727d43
commit 1854ca9591
1 changed files with 9 additions and 7 deletions

View File

@ -198,13 +198,6 @@ public class LocalSplitGenerator implements Generator {
public void shutdown() {
// shutdown threads
executorService.shutdown();
if (writerScheduler != null) {
try {
writerScheduler.cancel();
// writerScheduler.purge();
} catch (Exception e) {
}
}
// shutdown connection
stopInterrupt = true;
if (!distributionModel.isSynchronousProbabilityWrite()) {
@ -215,8 +208,17 @@ public class LocalSplitGenerator implements Generator {
}
}
}
if (writerScheduler != null) {
try {
writerScheduler.cancel();
writerScheduler.purge();
} catch (Exception e) {
}
}
AnalysisLogger.getLogger().trace("CLOSING CONNECTIONS");
dbHibConnection.close();
}
@Override