Repository: incubator-streams Updated Branches: refs/heads/master 4f6f7d5f5 -> 7f69bd450
STREAMS-252 | Added more logging Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/7f69bd45 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/7f69bd45 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/7f69bd45 Branch: refs/heads/master Commit: 7f69bd4507e4d6caa0de16c7a7a7c2faf52e7b64 Parents: 4f6f7d5 Author: Robert Douglas <rdoug...@w2ogroup.com> Authored: Thu Dec 11 17:33:36 2014 -0600 Committer: Robert Douglas <rdoug...@w2ogroup.com> Committed: Thu Dec 11 17:33:36 2014 -0600 ---------------------------------------------------------------------- .../java/org/apache/streams/local/builders/LocalStreamBuilder.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/7f69bd45/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java index bef5ed7..ae519e1 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java @@ -397,6 +397,7 @@ public class LocalStreamBuilder implements StreamBuilder { try { shutdown(tasks); } catch (Exception e) { + LOGGER.error("Exception while trying to shutdown Stream: {}", e); forceShutdown(tasks); } finally { if(!systemExiting) {
