Hey all, I'm building an topology on Storm, using Streams API, and for some reason, the topology doesn't work at all when using an three way join, what I mean with this is, I have three sources and I join the first two and then I join the last source with the previous Join result.
I already tested that if I only make only the join between 2 sources, the topology work perfectly, but if I make the same join and use that output to join with other source I receive exception like: Received punctuation from streams [s9] expected [s10] I don't really know if this is a problem on how StreamsBuilder, build the bolts and spout for hte topology I'm building or if is just something that I'm doing wrong. Conceptually what I' doing is: PairStream<> A = ... PairStream<> B =... PairStream<> C =... PairStream<> AB = A.window(....).join(B, ....); PairStream<> ABC = AB.window(....).join(C, ....); Best regards, Rúben Garcia
