@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
