I am very new to Apache Storm and Maven, but I am trying to deploy the
javascript topology from the starter examples in a local Storm cluster.
Here is the code I am using: https://github.com/apache/storm/tree/master/
examples/storm-starter
I am trying to use the WordCountTopologyNode class.
Everything goes well to submit the topology, but after couple seconds I get
the following error:
java.lang.RuntimeException: subprocess heartbeat timeout at
org.apache.storm.spout.ShellSpout$SpoutHeartbeatTimerTask.run(ShellSpout.java:322)
at java.util.concurrent.Executors$RunnableAdapter.call```
Looking at the worker logs, I can see the following:
[ERROR] Halting process: ShellSpout died. Command: [node,
randomsentence.js], ProcessInfo pid:61178, name:spout exitCode:-1,
errorString:
java.lang.RuntimeException: subprocess heartbeat timeout
at
org.apache.storm.spout.ShellSpout$SpoutHeartbeatTimerTask.run(ShellSpout.java:322)
[storm-core-1.1.0.jar:1.1.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_131]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
[?:1.8.0_131]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_131]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[?:1.8.0_131]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[?:1.8.0_131]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[?:1.8.0_131]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
I didn't change any code. Using exactly the starter examples as it is when
cloned.
Have anyone faced this issue before ?
It seems it can't load the js file ? Or maybe the js code is broken and
results in a timeout ?
Thanks!
--
Leonardo Ferreira
Sr. Fullstack Software Developer
