工人：無法連接到主站的火花阿帕奇

我嘗試部署使用獨立的集羣管理器Windows上的應用程序星火，所以在主端（IP：192。 .186），我跑：工人：無法連接到主站的火花阿帕奇

\bin>spark-class org.apache.spark.deploy.master.Master

，並在從站側（IP：192. 0.75）我跑：

\bin>spark-class org.apache.spark.deploy.worker.Worker spark://192.*.*.186:7077

我有一個問題，第e客戶端無法連接到主節點，這是我得到的錯誤：

17/09/26 12:00:51 WARN Worker: Failed to connect to master 192.*.*.186:7077 
org.apache.spark.SparkException: Exception thrown in awaitResult: 
    at org.apache.spark.util.ThreadUtils$.awaitResult(ThreadUtils.scala:205) 
    at org.apache.spark.rpc.RpcTimeout.awaitResult(RpcTimeout.scala:75) 
    at org.apache.spark.rpc.RpcEnv.setupEndpointRefByURI(RpcEnv.scala:100) 
    at org.apache.spark.rpc.RpcEnv.setupEndpointRef(RpcEnv.scala:108) 
    at org.apache.spark.deploy.worker.Worker$$anonfun$org$apache$spark$deploy$worker$Worker$$tryRegisterAllMasters$1$$anon$1.run(Worker.scala:241) 
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
    at java.util.concurrent.FutureTask.run(FutureTask.java:266) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 
    at java.lang.Thread.run(Thread.java:745) 
Caused by: java.io.IOException: Failed to connect to /192.*.*.186:7077 
    at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:232) 
    at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:182) 
    at org.apache.spark.rpc.netty.NettyRpcEnv.createClient(NettyRpcEnv.scala:197) 
    at org.apache.spark.rpc.netty.Outbox$$anon$1.call(Outbox.scala:194) 
    at org.apache.spark.rpc.netty.Outbox$$anon$1.call(Outbox.scala:190) 
    ... 4 more 
Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /192.*.*.186:7077 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) 
    at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:257) 
    at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:291) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:631) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:566) 
    at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:480) 
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:442) 
    at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) 
    at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144) 
    ... 1 more

我該如何解決這個問題？

來源

2017-09-26 Mèhdi Ben Hamida

測試兩臺機器之間的連接？ –

bin>spark-class org.apache.spark.deploy.worker.Worker spark://192.*.*.186:7077

上述命令中提到的master-ip是否正確？

你寫道，主ip是192 ... 168，但在奴隸啓動命令你用192嘗試。。。，錯字：6和8倒轉

來源

2017-09-26 11:05:14

好的，那麼你可以嘗試使用以下命令從slave box到master進行telnet。 > telnet master-ip 7077 –

此外，在文件中添加以下行：SPARK_HOME/conf/spark-env.sh 'SPARK_MASTER_IP = 192 ... 186' 然後重新啓動工作站或主站中的火花主站 –

？ –

工人：無法連接到主站的火花阿帕奇

回答

相關問題