Thanks a lot. Now it's working fine. I wasn't aware of "socketTextStream",
not sure if it was documented in the spark programming guide.
On Mon, Sep 21, 2015 at 12:46 PM, Hemant Bhanawat
wrote:
> Why are you using rawSocketStream to read the data? I believe
> rawSocketStream waits for a big chu
Why are you using rawSocketStream to read the data? I believe
rawSocketStream waits for a big chunk of data before it can start
processing it. I think what you are writing is a String and you should use
socketTextStream which reads the data on a per line basis.
On Sun, Sep 20, 2015 at 9:56 AM, Sa
