Re: Spark Streaming not reading input coming from the other ip

Thanks Shixiong, I am not getting any error and telnet is also working fine. $ telnet Trying 192.168.186.97... Connected to ttsv- On Mon, Feb 22, 2016 at 1:10 PM, Shixiong(Ryan) Zhu wrote: > What's the error info reported by Streaming? And could you use

Re: Spark Streaming not reading input coming from the other ip

What's the error info reported by Streaming? And could you use "telnet" to test if the network is normal? On Mon, Feb 22, 2016 at 6:59 AM, Vinti Maheshwari wrote: > For reference, my program: > > def main(args: Array[String]): Unit = { > val conf = new

Re: Spark Streaming not reading input coming from the other ip

For reference, my program: def main(args: Array[String]): Unit = { val conf = new SparkConf().setAppName("HBaseStream") val sc = new SparkContext(conf) // create a StreamingContext, the main entry point for all streaming functionality val ssc = new StreamingContext(sc, Seconds(2))

Spark Streaming not reading input coming from the other ip

Hi I am in spark Streaming context, and i am reading input from the the socket using nc -lk . When i am running it and manually giving input it's working. But, if input is coming from different ip to this socket then spark is not reading that input, though it's showing all the input coming