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