samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shekar Tippur <ctip...@gmail.com>
Subject Re: Samza as a Caching layer
Date Fri, 05 Sep 2014 06:19:50 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message