Hi Shekar, Sorry for so much trouble. I guess we miss some pieces here. Let's make sure something:
1. which branch of hello-samza are you using? latest or master? (suggest master) (I ask this is because by default, the hello-samza already contains the log4j and slf4j dependencies. A little confused since you have to add the dependencies by yourself) 2. when you run bin/produce-wikipedia-raw-data.sh, can you see the wikipedia-raw topic gets messages in Kafka? 3. since you are running in local mode, if you are using the master branch (which is using samza 0.7.0), could you change job.factory.class=org.apache.samza.job.*yarn.YarnJobFactory* to job.factory.class=org.apache.samza.job.*local.LocalJobFactory * in wikipedia-feed.properties ? Then restart the samza job. Let me know how it goes. :) Thank you. Cheers, Fang, Yan [email protected] +1 (206) 849-4108 On Thu, Sep 4, 2014 at 4:32 PM, Shekar Tippur <[email protected]> wrote: > Yan, > > 1. Added a debug statement to > > samza-wikipedia/src/main/java/samza/examples/wikipedia/task/WikipediaParserStreamTask.java > > System.out.println("Incoming stream " + envelope.getMessage().toString()); > > 2. ran mvn clean install > > 3. tar'd the folder as instructed > > 4. Ensured that Kafka is running > > 5. Ran deploy/samza/bin/run-job.sh > --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory > > --config-path=/home/ctippur/incubator-samza-hello-samza/deploy/samza/config/wikipedia-parser.properties > > 6. ran bin/produce-wikipedia-raw-data.sh to generate some feeds.. > > I am not seeing anything on the console. I am not seeing anything > registered to yarn as well. Clearly I am doing something wrong .. > > - Shekar > > > > > On Thu, Sep 4, 2014 at 1:01 PM, Shekar Tippur <[email protected]> wrote: > > > Yan - > > > > Thanks a lot for your input. That makes sense. I will give it a shot now. > > > > - Shekar > > >
