Hi Camel Hadoop is hosted outside Apache and thus not officially supported by Apache etc. I think you gotta dig into it yourself to see the issue.
Normally doStart should be invoked on a Producer/Consumer if it extends the DefaultProducer/DefaultConsumer etc. And I am sure patches etc is welcome on the Camel Hadop project. On Mon, Mar 22, 2010 at 5:57 PM, Vinicius Carvalho <[email protected]> wrote: > Hello there! I'm trying the Camel Hadoop integration (using > camel-2.3-Snapshot), and using this producer: > > @Produce(uri="hdfs://localhost/temp/tweets?splitStrategy=BYTES:200000") > protected TweeterProducer producer; > > The problem is that I get a NPE: > > Exception in thread "Twitter Stream Handling Thread[receiving stream]" > org.apache.camel.RuntimeCamelException: java.lang.NullPointerException > at > org.apache.camel.component.hdfs.HdfsProducer.process(HdfsProducer.java:176) > at > org.apache.camel.component.bean.CamelInvocationHandler.invoke(CamelInvocationHandler.java:64) > at $Proxy32.broadcast(Unknown Source) > at > com.acme.tweet.TwitterBroadcaster.onStatus(TwitterBroadcaster.java:39) > at twitter4j.StatusStream.next(StatusStream.java:78) > at > twitter4j.TwitterStream$StreamHandlingThread.run(TwitterStream.java:357) > > Checking the HdfsProducer code, I can verify that it seems that when > process is called, the variable > > HdfsOutputStream ostream is not set. I do not know the internals of > camel, but it seems that this component does not get the doStart() > called prior to the process method. And it seems thats how it should > happen. > > Any ideas? > > Regards > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
