RE: Streaming Application Unable to get Stream from Kafka

2015-10-12 Thread Prateek .
: Streaming Application Unable to get Stream from Kafka Hi Prateek, How many cores (threads) do you assign to spark in local mode? It is very likely the local spark does not have enough resource to proceed. You can check http://yourip:4040 to check the details. Thanks! Terry On Fri, Oct 9, 2015 at 10

Re: Streaming Application Unable to get Stream from Kafka

2015-10-09 Thread Terry Hoo
Hi Prateek, How many cores (threads) do you assign to spark in local mode? It is very likely the local spark does not have enough resource to proceed. You can check http://yourip:4040 to check the details. Thanks! Terry On Fri, Oct 9, 2015 at 10:34 PM, Prateek . wrote: > Hi All, > > > > In my

RE: Streaming Application Unable to get Stream from Kafka

2015-10-09 Thread Prateek .
Hi All, In my application I have a serializable class which is taking InputDStream from Kafka. The inputDStream contains JSON which is stored in serializable case class. Transformations are applied and saveToCassandra() is executed. I was getting task not serializable exception , so I made the