James Lampton created STORM-368:
-----------------------------------
Summary: Trident groupBy().aggregate() produces no results if
Spout.nextTuple always emits
Key: STORM-368
URL: https://issues.apache.org/jira/browse/STORM-368
Project: Apache Storm (Incubating)
Issue Type: Bug
Affects Versions: 0.9.2-incubating
Reporter: James Lampton
I was debugging an issue with Pig-Squeal and noticed that my Combine
Aggregators weren't working with the RandomSentenceSpout. After some
investigation, I discovered that no values are emitted from the aggregate if
the underlying Spout always emits tuples.
I will attach a test case to demonstrate shortly.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
