You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/07/18 18:13:36 UTC
git commit: STREAMS-131 | Updated per code review comment
Repository: incubator-streams
Updated Branches:
refs/heads/STREAMS-131 c343a1b00 -> e1f8eea7c
STREAMS-131 | Updated per code review comment
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/e1f8eea7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/e1f8eea7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/e1f8eea7
Branch: refs/heads/STREAMS-131
Commit: e1f8eea7c1eb13608f6396472f7a9df3a07a4b44
Parents: c343a1b
Author: mfranklin <mf...@apache.org>
Authored: Fri Jul 18 12:13:23 2014 -0400
Committer: mfranklin <mf...@apache.org>
Committed: Fri Jul 18 12:13:23 2014 -0400
----------------------------------------------------------------------
.../java/org/apache/streams/local/tasks/StreamsProviderTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/e1f8eea7/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
index 88f6f48..f5189eb 100644
--- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
+++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
@@ -174,8 +174,8 @@ public class StreamsProviderTask extends BaseStreamsTask implements DatumStatusC
LOGGER.error("Error in processing provider stream", e);
} finally {
LOGGER.debug("Complete Provider Task execution for {}", this.provider.getClass().getSimpleName());
- this.keepRunning.set(false);
this.provider.cleanUp();
+ this.keepRunning.set(false);
}
}