Aha, yes, we are almost there. I think I made a mistake in the previous email.
1. modify the *wikipedia-parser.properties , NOT *wikipedia-feed.properties 2. run deploy/samza/bin/run-job.sh --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory --config-path=file://$PWD/deploy/samza/config/*wikipedia-parser.properties* *(NOT *wikipedia-feed,properties*)* Then you should see the messages in the kafka topic, *wikipedia-edits* Thanks. Let me know if you have any luck . :) Cheers, Fang, Yan [email protected] +1 (206) 849-4108 On Thu, Sep 4, 2014 at 11:19 PM, Shekar Tippur <[email protected]> wrote: > Just tried #3. Changed the property file wikipedia-feed.properties > > job.factory.class=org.apache.samza.job.local.LocalJobFactory > Ran .. > > deploy/samza/bin/run-job.sh > --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory > > --config-path=file:///home/ctippur/hello-samza/deploy/samza/config/wikipedia-feed.properties > > I dont see any debug messages that I added to the feed or the parser file.. > I see messages on the kafka-consumer .. > > However the feed job died with the below message > > > Exception in thread "ThreadJob" java.lang.RuntimeException: Trying to > unlisten to a channel that has no listeners in it. > > at > > samza.examples.wikipedia.system.WikipediaFeed.unlisten(WikipediaFeed.java:98) > > at > > samza.examples.wikipedia.system.WikipediaConsumer.stop(WikipediaConsumer.java:72) > > at > > org.apache.samza.system.SystemConsumers$$anonfun$stop$2.apply(SystemConsumers.scala:152) > > at > > org.apache.samza.system.SystemConsumers$$anonfun$stop$2.apply(SystemConsumers.scala:152) > > at scala.collection.Iterator$class.foreach(Iterator.scala:727) > > at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) > > at > scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206) > > at org.apache.samza.system.SystemConsumers.stop(SystemConsumers.scala:152) > > at > > org.apache.samza.container.SamzaContainer.shutdownConsumers(SamzaContainer.scala:587) > > at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:512) > > at org.apache.samza.job.local.ThreadJob$$anon$1.run(ThreadJob.scala:42) > > - Shekar >
