Re: Question on camel-hdfs

[dgreco <gr...@acm.org>]

Sorry,
I found this only now, if you want I could give you some help since I'm the
contributor of the camel-hdfs component. 
regards,
David


Vinicius Carvalho 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
> 
> 

-- 
View this message in context: http://old.nabble.com/Question-on-camel-hdfs-tp27989295p28278299.html
Sent from the Camel - Users mailing list archive at Nabble.com.