: 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
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
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