How many workers did you configure (ie, storm.yaml parameter "supervisor.slots.ports" -- the number of available slots is also shown in the web UI)?
If there are free workers available, look into logs/worker*.log -- if
worker*.log is not available, no worker was started. You might also have
a look into logs/supervisor.log and maybe logs/nimbus.log
-Matthias
On 05/23/2016 08:55 AM, Navin Ipe wrote:
> 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=2000
> initLimit=10
> syncLimit=5
> dataDir=/Users/nav/programming/zookeeper-3.4.8/data
> clientPort=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 SUCCESSFUL
>
> Total time: 12.78 secs
>
> This build could be faster, please consider using the Gradle Daemon:
> 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:-9035830007806332208
> 1074 [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.jar
> 1271 [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.jar
> 1271 [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:
> MyTopology
> 1427 [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
signature.asc
Description: OpenPGP digital signature
