Hi,
I'm a newbie with Spark,, I'm just trying to use SparkStreaming and
filter some data sent with a Java Socket but it's not working... it
works when I use ncat
Why is it not working??
My sparkcode is just this:
val sparkConf = new SparkConf().setMaster("local[2]").setAppName("Test")
val ssc = new StreamingContext(sparkConf, Seconds(5))
val lines = ssc.socketTextStream("localhost", 9999)
val errorLines = lines.filter(_.contains("hello"))
errorLines.print()
I created a client socket which sends data to that port, but it could
connect any address, I guess that Spark doesn't work like a
serverSocket... what's the way to send data from a socket with Java to
be able to read from socketTextStream??
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
