Hah, thanks for tidying up the paper trail here, but I was the OP (and solver) of the recent "reduce" thread that ended in this solution.
On Sun, Jul 13, 2014 at 4:26 PM, Michael Campbell < michael.campb...@gmail.com> wrote: > Make sure you use "local[n]" (where n > 1) in your context setup too, (if > you're running locally), or you won't get output. > > > On Sat, Jul 12, 2014 at 11:36 PM, Walrus theCat <walrusthe...@gmail.com> > wrote: > >> Thanks! >> >> I thought it would get "passed through" netcat, but given your email, I >> was able to follow this tutorial and get it to work: >> >> >> http://docs.oracle.com/javase/tutorial/networking/sockets/clientServer.html >> >> >> >> >> On Fri, Jul 11, 2014 at 1:31 PM, Sean Owen <so...@cloudera.com> wrote: >> >>> netcat is listening for a connection on port 9999. It is echoing what >>> you type to its console to anything that connects to 9999 and reads. >>> That is what Spark streaming does. >>> >>> If you yourself connect to 9999 and write, nothing happens except that >>> netcat echoes it. This does not cause Spark to somehow get that data. >>> nc is only echoing input from the console. >>> >>> On Fri, Jul 11, 2014 at 9:25 PM, Walrus theCat <walrusthe...@gmail.com> >>> wrote: >>> > Hi, >>> > >>> > I have a java application that is outputting a string every second. >>> I'm >>> > running the wordcount example that comes with Spark 1.0, and running >>> nc -lk >>> > 9999. When I type words into the terminal running netcat, I get counts. >>> > However, when I write the String onto a socket on port 9999, I don't >>> get >>> > counts. I can see the strings showing up in the netcat terminal, but >>> no >>> > counts from Spark. If I paste in the string, I get counts. >>> > >>> > Any ideas? >>> > >>> > Thanks >>> >> >> >
