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
