spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sean Owen <so...@cloudera.com>
Subject Re: unable to run streaming
Date Thu, 13 Nov 2014 10:14:39 GMT
I suppose it means what it says, that you it can't connect, but that's
strange to be unable to connect to a port on localhost.

What if you "telnet localhost 9999" and type some text? does it show
up in the nc output? if not, it's some other problem locally, like a
firewall, or nc not running, or not actually running all this on one
host, etc.

On Thu, Nov 13, 2014 at 10:06 AM, Niko Gamulin <niko.gamulin@gmail.com> wrote:
> 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
>

---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscribe@spark.apache.org
For additional commands, e-mail: user-help@spark.apache.org


Mime
View raw message