I installed zookeeper on my local system. Started it. Extracted Storm 1.0.1
on my local system and *started it via this script:*
*#!/bin/bash./storm nimbus &./storm supervisor &./storm ui &*
*storm.yaml has:*
* storm.zookeeper.servers: - "localhost" nimbus.seeds: ["localhost"]*
*and zoo.conf has:*
*tickTime=2000initLimit=10syncLimit=5dataDir=/Users/nav/programming/zookeeper-3.4.8/dataclientPort=2181*
*Using this version of Storm via Gradle.*
*dependencies { compile 'org.apache.storm:storm-core:1.0.1'*
*Firewall on my system*
Switched off
*and submitting topology like this:*
*System.setProperty("storm.jar",
"/Users/nav/programming/apache-storm-1.0.1/lib/storm-core-1.0.1.jar");
StormSubmitter.submitTopology(c.TOPO_NAME, config,
builder.createTopology());*
But on running it in my program's build/lib folder with java -jar
myProgram.jar, the topology gets submitted (and I can see the submitted
topology on the storm UI via http://localhost:8080),* but after submitting,
no emits happen. The program seems to freeze.*
*BUILD SUCCESSFULTotal time: 12.78 secsThis build could be faster, please
consider using the Gradle Daemon:
https://docs.gradle.org/2.10/userguide/gradle_daemon.html
<https://docs.gradle.org/2.10/userguide/gradle_daemon.html>569 [main]
INFO c.s.c.s.Queries_ReaderWriter - Waiting few seconds until table is
dropped...589 [main] INFO c.s.c.s.Queries_ReaderWriter - New table
created.1007 [main] INFO o.a.s.StormSubmitter - Generated ZooKeeper secret
payload for MD5-digest: -5943870921993217077:-90358300078063322081074
[main] INFO o.a.s.s.a.AuthUtils - Got AutoCreds []1124 [main] INFO
o.a.s.StormSubmitter - Uploading topology jar
/Users/nav/programming/apache-storm-1.0.1/lib/storm-core-1.0.1.jar to
assigned location:
/Users/nav/programming/apache-storm-1.0.1/storm-local/nimbus/inbox/stormjar-036472f9-15ce-4f09-8663-b1500942e696.jar1271
[main] INFO o.a.s.StormSubmitter - Successfully uploaded topology jar to
assigned location:
/Users/nav/programming/apache-storm-1.0.1/storm-local/nimbus/inbox/stormjar-036472f9-15ce-4f09-8663-b1500942e696.jar1271
[main] INFO o.a.s.StormSubmitter - Submitting topology MyTopology in
distributed mode with conf
{"storm.zookeeper.topology.auth.scheme":"digest","topology.workers":2,"topology.debug":false,"topology.max.spout.pending":10,"storm.zookeeper.topology.auth.payload":"-5943870921993217077:-9035830007806332208","topology.transfer.buffer.size":32,"topology.executor.send.buffer.size":16384,"topology.executor.receive.buffer.size":16384}1427
[main] INFO o.a.s.StormSubmitter - Finished submitting topology:
MyTopology1427 [main] INFO c.s.c.CrystalStorm - Topology submitted*
*Two questions:*
1. What usually causes this kind of problem? I've seen the answers on
StackOverflow, but they didn't help.
2. Which log files would provide the most useful info in such situations?
--
Regards,
Navin
