Hi,
I have tried to run basic streaming example (
https://spark.apache.org/docs/1.1.0/streaming-programming-guide.html)
I have established two ssh connections to the machine where spark is
installed. In one terminal, I have started netcat with command
nc -lk 9999
In other terminal I have run the command
./bin/run-example streaming.NetworkWordCount localhost 9999
I get the following error and haven't managed to diagnose the cause:
14/11/13 13:03:43 ERROR ReceiverTracker: Deregistered receiver for stream
0: Restarting receiver with delay 2000ms: Error connecting to
localhost:9999 - java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391)
at java.net.Socket.connect(Socket.java:579)
at java.net.Socket.connect(Socket.java:528)
at java.net.Socket.<init>(Socket.java:425)
at java.net.Socket.<init>(Socket.java:208)
at
org.apache.spark.streaming.dstream.SocketReceiver.receive(SocketInputDStream.scala:71)
at
org.apache.spark.streaming.dstream.SocketReceiver$$anon$2.run(SocketInputDStream.scala:57)
-------------------------------------------
Time: 1415880224000 ms
-------------------------------------------
If anyone encountered the same problem and solved the issue, I would be
very thankful if you could describe how to solve the problem or what could
cause it.
Best regards,
Niko
