When you are sending data using simple socket code to send messages, are those messages "\n" delimited? If its not, then the receiver of socketTextSTream, wont identify them as separate events, and keep buffering them.
TD On Sun, Jul 13, 2014 at 10:49 PM, kytay <kaiyang....@gmail.com> wrote: > Hi Tobias > > I have been using "local[4]" to test. > My problem is likely caused by the tcp host server that I am trying the > emulate. I was trying to emulate the tcp host to send out messages. > (although I am not sure at the moment :D) > > First way I tried was to use a tcp tool called, Hercules. > > Second way was to write a simple socket code to send message at interval. > Like the one shown in #2 of my first post. I suspect the reason why it > don't > work is due the messages are not "flush" so no message was received on > Spark > Streaming. > > I think I will need to do more testing to understand the behavior. I am > currently not sure why "nc -lk" is working, and not the other tools or > codes > I am testing with. > > Regards. > > > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Solved-Streaming-Cannot-get-socketTextStream-to-receive-anything-tp9382p9588.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >
