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