@eric-
i saw this exact issue recently while working on the KinesisWordCount.
are you passing "local[2]" to your example as the MASTER arg versus just
"local" or "local[1]"?
you need at least 2. it's documented as "n>1" in the scala source docs -
which is easy to mistake for n>=1.
i just ran t
Not sure what data you are sending in. You could try calling
"lines.print()" instead which should just output everything that comes in
on the stream. Just to test that your socket is receiving what you think
you are sending.
On Mon, Mar 31, 2014 at 12:18 PM, eric perler wrote:
> Hello
>
> i ju
Hello
i just started working with spark today... and i am trying to run the wordcount
network example
i created a socket server and client.. and i am sending data to the server in
an infinite loop
when i run the spark class.. i see this output in the console...
---
