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
