Hello, I'm build an topology using Stream API from Storm 2.2.0 and I'm having some problems when making two joins, with the concept of Streams A,B and C, joining A and B returns AB and then joining AB with C. (For this case to be analyzed the built topology can be found here from line 59 to 89 - https://github.com/RubenRibGarcia/infrastructure-and-programming-models-for-stream-data-analysis/blob/master/spds-benchmark/spds-storm/spds-storm-gira-topology/src/main/java/org/isel/thesis/impads/storm/streams/topology/GiraTravelsStreamTopologyBuilder.java#L59 )
For some reason this last join produces the current exception: java.lang.IllegalStateException: Received punctuation from streams [s10] expected [s8] at org.apache.storm.streams.ProcessorBoltDelegate.shouldPunctuate(ProcessorBoltDelegate.java:287) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.streams.ProcessorBoltDelegate.punctuateInitialProcessors(ProcessorBoltDelegate.java:189) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.streams.ProcessorBoltDelegate.process(ProcessorBoltDelegate.java:179) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.streams.WindowedProcessorBolt.execute(WindowedProcessorBolt.java:68) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.topology.WindowedBoltExecutor.boltExecute(WindowedBoltExecutor.java:371) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.topology.WindowedBoltExecutor$1.onActivation(WindowedBoltExecutor.java:364) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.WindowManager.onTrigger(WindowManager.java:156) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.TimeTriggerPolicy$1.run(TimeTriggerPolicy.java:119) [storm-client-2.2.0.jar:2.2.0] at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) [?:?] at java.util.concurrent.FutureTask.runAndReset(Unknown Source) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [?:?] at java.lang.Thread.run(Unknown Source) [?:?] 2020-11-15 19:21:27.819 o.a.s.w.TimeTriggerPolicy Thread-14-bolt4-executor[6, 6] [ERROR] Got exception java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Received punctuation from streams [s10] expected [s8] at java.util.concurrent.FutureTask.report(Unknown Source) ~[?:?] at java.util.concurrent.FutureTask.get(Unknown Source) ~[?:?] at org.apache.storm.windowing.TimeTriggerPolicy.checkFailures(TimeTriggerPolicy.java:96) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.TimeTriggerPolicy.track(TimeTriggerPolicy.java:54) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.WindowManager.track(WindowManager.java:185) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.WindowManager.add(WindowManager.java:121) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.WindowManager.add(WindowManager.java:106) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.WindowManager.add(WindowManager.java:96) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.topology.WindowedBoltExecutor.execute(WindowedBoltExecutor.java:320) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.executor.bolt.BoltExecutor.tupleActionFn(BoltExecutor.java:236) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.executor.Executor.accept(Executor.java:283) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:131) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.utils.JCQueue.consume(JCQueue.java:111) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:172) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.executor.bolt.BoltExecutor$1.call(BoltExecutor.java:159) [storm-client-2.2.0.jar:2.2.0] at org.apache.storm.utils.Utils$1.run(Utils.java:394) [storm-client-2.2.0.jar:2.2.0] at java.lang.Thread.run(Unknown Source) [?:?] Caused by: java.lang.IllegalStateException: Received punctuation from streams [s10] expected [s8] at org.apache.storm.streams.ProcessorBoltDelegate.shouldPunctuate(ProcessorBoltDelegate.java:287) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.streams.ProcessorBoltDelegate.punctuateInitialProcessors(ProcessorBoltDelegate.java:189) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.streams.ProcessorBoltDelegate.process(ProcessorBoltDelegate.java:179) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.streams.WindowedProcessorBolt.execute(WindowedProcessorBolt.java:68) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.topology.WindowedBoltExecutor.boltExecute(WindowedBoltExecutor.java:371) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.topology.WindowedBoltExecutor$1.onActivation(WindowedBoltExecutor.java:364) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.WindowManager.onTrigger(WindowManager.java:156) ~[storm-client-2.2.0.jar:2.2.0] at org.apache.storm.windowing.TimeTriggerPolicy$1.run(TimeTriggerPolicy.java:119) ~[storm-client-2.2.0.jar:2.2.0] at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) ~[?:?] at java.util.concurrent.FutureTask.runAndReset(Unknown Source) ~[?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?] ... 1 more Hope this may be sufficient to help me fix this problem, somehow. Best regards, Rúben Garcia
