Fixed merge error
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/79eadea2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/79eadea2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/79eadea2 Branch: refs/heads/STREAMS-49 Commit: 79eadea2453610075236e1fed13c215bee474592 Parents: 377fb89 Author: Ryan Ebanks <[email protected]> Authored: Fri Oct 31 17:00:47 2014 -0500 Committer: Ryan Ebanks <[email protected]> Committed: Fri Oct 31 17:00:47 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/streams/local/tasks/StreamsProcessorTask.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/79eadea2/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProcessorTask.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProcessorTask.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProcessorTask.java index 33c5827..b6ab498 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProcessorTask.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProcessorTask.java @@ -127,6 +127,7 @@ public class StreamsProcessorTask extends BaseStreamsTask implements DatumStatus if(output != null) { for(StreamsDatum outDatum : output) { super.addToOutgoingQueue(outDatum); + this.counter.incrementEmittedCount(); statusCounter.incrementStatus(DatumStatus.SUCCESS); } }
