storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rúben Garcia <rubenribeirogar...@gmail.com>
Subject Received punctuation from streams X expected Y - Streams API - Storm 2.2.0
Date Sun, 15 Nov 2020 19:31:11 GMT
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

Mime
View raw message