Was the topology assigned to a supervisor (check the UI)? Were there enough worker slots in your cluster to support the topology's requirements? Is the supervisor running on the same machine as you're launching from? Does the text file exist on the supervisor node?
On Thu, Jan 30, 2014 at 10:47 AM, Roberto Coluccio < [email protected]> wrote: > Hello, > > I'm developing a sample application based on one spout that reads lines of > text from files and several bolts that process these lines. > > I've run my topology in local mode with no problems using both storm 0.8.2 > and 0.9.0.1. My run configuration starts exporting into a ANT file my > eclipse (java 7-based) project. After removing all storm jar dependencies > from ANT.xml I run as ANT build it in order to get the runnable jar > created. Then, I run the command: > > *<storm-dir>/bin/storm jar <path-of-the-jar> <main-class> <args>* > > and it properly run. > > I'm now trying to run the topology in cluster mode but on a single > machine. I've installed Zookeeper 3.4.5, 0MQ and JZMQ following the storm > tutorial. Obviously I've configured the zoo.cfg file in > <zookeeper-dir>/conf and placed the storm.yaml file in ~/.storm and > <storm-dir>/conf. Than I've run Zookeeper (<zookeeper-dir>/bin/zkServer.sh > start), storm nimbus, storm supervisor and I've tried to submit the > topology using the same command written above. It seems to be properly > submitted reading the following log: > > *722 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to > master yet. Submitting jar...* > *740 [main] INFO backtype.storm.StormSubmitter - Uploading topology jar > /<my-project-dir>/<my-project>.jar to assigned location: > /<storm-dir>/tmp/nimbus/inbox/stormjar-13666213-c32a-498e-861e-b47b8821172b.jar* > *868 [main] INFO backtype.storm.StormSubmitter - Successfully uploaded > topology jar to assigned location: > /<storm-dir>/tmp/nimbus/inbox/stormjar-13666213-c32a-498e-861e-b47b8821172b.jar* > *868 [main] INFO backtype.storm.StormSubmitter - Submitting topology > MY_TOPOLOGY in distributed mode with conf > {"topology.max.task.parallelism":3,"topology.workers":3,"topology.debug":false}* > *1464 [main] INFO backtype.storm.StormSubmitter - Finished submitting > topology: MY_TOPOLOGY* > > At this point, it seems like the topology is not running. Nothing happens, > except from the appearing of the line (I mentioned in the object) on the > "./storm supervisor" terminal window : > > *caution: filename not matched: resources/*** > > The spout reads some text files from a given absolute path ( > /<my-project-dir>/resources/ ). Running the topology in local mode I have > no problems at all. I have an openjdk 7 installed on an Ubuntu 13.04 64bit > machine. > > I really can't understand what is happening here, please help me out! > > Thank you in advance. > > Roberto >
