1. ホーム
  2. 質問と答え
  3. スパーククラスター起動問題

スパーククラスター起動問題

2017-01-11 24 views
0

スパーククラスターのセットアップを開始しようとしています。私はスパーククラスターの状態を確認したりセットアップしたりすることに従いましたが、ステータスについてはわかりません。スパーククラスター起動問題

ブラウザでmaster-ip：8081（8080,4040,4041）をチェックしようとしましたが、結果が見当たりませんでした。まず始めに、私はセットアップし、ハープクラスターを開始しました。

JPS gives: 

2436 SecondaryNameNode 
2708 NodeManager 
2151 NameNode 
5495 Master 
2252 DataNode 
2606 ResourceManager 
5710 Jps

質問は（それが必要なのHadoopを開始することでした？）マスターは/ usr/local /火花/ confに/スレーブで

localhost 
slave-node-1 
slave-node-2

さて、スパークを開始します。マスター

$SPARK_HOME/sbin/start-master.sh

を開始し、スレーブノードで

ps -ef|grep spark 
    hduser 5495  1 0 18:12 pts/0 00:00:04 /usr/local/java/bin/java -cp /usr/local/spark/conf/:/usr/local/spark/jars/*:/usr/local/hadoop/etc/hadoop/ -Xmx1g org.apache.spark.deploy.master.Master --host master-hostname --port 7077 --webui-port 8080

スレーブノード2

に 

ps -ef|grep spark 
hduser 1847  1 20 18:24 pts/0 00:00:04 /usr/local/java/bin/java -cp /usr/local/spark/conf/:/usr/local/spark/jars/* -Xmx1g org.apache.spark.deploy.worker.Worker --webui-port 8081 spark://master-ip:7077

同じでテスト1

$SPARK_HOME/sbin/start-slave.sh spark://205.147.102.19:7077

でテスト 

$SPARK_HOME/sbin/start-slave.sh spark://master-ip:7077 
    ps -ef|grep spark 
    hduser 1948  1 3 18:18 pts/0 00:00:03 /usr/local/java/bin/java -cp /usr/local/spark/conf/:/usr/local/spark/jars/* -Xmx1g org.apache.spark.deploy.worker.Worker --webui-port 8081 spark://master-ip:7077

Webコンソール上でspark ..の何も見ることができなかったので、ファイアウォールに問題があると考えられました。私のiptablesはここにあります。

iptables -L -nv 
    Chain INPUT (policy ACCEPT 0 packets, 0 bytes) 
    pkts bytes target  prot opt in  out  source    destination   
    6136 587K fail2ban-ssh tcp -- *  *  0.0.0.0/0   0.0.0.0/0   multiport dports 22 
    151K 25M ACCEPT  all -- *  *  0.0.0.0/0   0.0.0.0/0   state RELATED,ESTABLISHED 
    6 280 ACCEPT  icmp -- *  *  0.0.0.0/0   0.0.0.0/0   
    579 34740 ACCEPT  all -- lo  *  0.0.0.0/0   0.0.0.0/0   
    34860 2856K ACCEPT  all -- eth1 *  0.0.0.0/0   0.0.0.0/0   
    145 7608 ACCEPT  tcp -- *  *  0.0.0.0/0   0.0.0.0/0   state NEW tcp dpt:22 
    56156 5994K REJECT  all -- *  *  0.0.0.0/0   0.0.0.0/0   reject-with icmp-host-prohibited 
    0  0 ACCEPT  tcp -- *  *  0.0.0.0/0   0.0.0.0/0   tcp dpt:8080 
    0  0 ACCEPT  tcp -- *  *  0.0.0.0/0   0.0.0.0/0   tcp dpt:8081 

    Chain FORWARD (policy ACCEPT 0 packets, 0 bytes) 
    pkts bytes target  prot opt in  out  source    destination   
    0  0 REJECT  all -- *  *  0.0.0.0/0   0.0.0.0/0   reject-with icmp-host-prohibited 

Chain OUTPUT (policy ACCEPT 3531 packets, 464K bytes) 
pkts bytes target  prot opt in  out  source    destination   

Chain fail2ban-ssh (1 references) 
pkts bytes target  prot opt in  out  source    destination   
2 120 REJECT  all -- *  *  218.87.109.153  0.0.0.0/0   reject-with icmp-port-unreachable 
5794 554K RETURN  all -- *  *  0.0.0.0/0   0.0.0.0/0

私は、spark-clusterが設定されているかどうか、またそれを正しく確認する方法を見ています。そして、クラスタが設定されている場合、なぜWebコンソール上でそれを確認できないのですか？何が間違っていますか？任意のポインタが参考になる...

EDIT - の

17/01/11 18:22:46 INFO Worker: Connecting to master master:7077... 
17/01/11 18:22:46 WARN Worker: Failed to connect to master master:7077

トンnodes-スレーブで（マスタに）ローカルコマンド--master火花シェル後

17/01/11 18:12:46 INFO util.Utils: Successfully started service 'sparkMaster' on port 7077. 
17/01/11 18:12:47 INFO master.Master: Starting Spark master at spark://master:7077 
17/01/11 18:12:47 INFO master.Master: Running Spark version 2.1.0 
17/01/11 18:12:47 INFO util.log: Logging initialized @3326ms 
17/01/11 18:12:47 INFO server.Server: jetty-9.2.z-SNAPSHOT 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/app,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/app/json,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/json,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/static,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/app/kill,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/driver/kill,null,AVAILABLE} 
17/01/11 18:12:47 INFO server.ServerConnector: Started [email protected]{HTTP/1.1}{0.0.0.0:8080} 
17/01/11 18:12:47 INFO server.Server: Started @3580ms 
17/01/11 18:12:47 INFO util.Utils: Successfully started service 'MasterUI' on port 8080. 
17/01/11 18:12:47 INFO ui.MasterWebUI: Bound MasterWebUI to 0.0.0.0, and started at http://master:8080 
17/01/11 18:12:47 INFO server.Server: jetty-9.2.z-SNAPSHOT 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/,null,AVAILABLE} 
17/01/11 18:12:47 INFO server.ServerConnector: Started [email protected]{HTTP/1.1}{master:6066} 
17/01/11 18:12:47 INFO server.Server: Started @3628ms 
17/01/11 18:12:47 INFO util.Utils: Successfully started service on port 6066. 
17/01/11 18:12:47 INFO rest.StandaloneRestServer: Started REST server for submitting applications on port 6066 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/metrics/master/json,null,AVAILABLE} 
17/01/11 18:12:47 INFO handler.ContextHandler: Started [email protected]{/metrics/applications/json,null,AVAILABLE} 
17/01/11 18:12:47 INFO master.Master: I have been elected leader! New state: ALIVE

をログに記録を追加しますJavaエラー..

17/01/11 18:31:18 ERROR Worker: All masters are unresponsive! Giving up.

出典

2017-01-11 tired and bored dev

答えて

1

SparkContextを作成するときにSpark Web UIが開始されます

spark-shell --master yourmaster:7077を実行してからSpark UIを開きます。 spark-sumitを使用してアプリケーションを送信して、SparkContextを作成することもできます。スパークdocumentationから

例​​、：最初の質問へ

./bin/spark-submit \ 
    --class org.apache.spark.examples.SparkPi \ 
    --master spark://207.184.161.138:7077 \ 
    --deploy-mode cluster \ 
    --supervise \ 
    --executor-memory 20G \ 
    --total-executor-cores 100 \ 
    /path/to/examples.jar \ 
    1000

回答：あなたはHDFSや糸を使用したい場合は、Hadoopのコンポーネントを起動する必要があります。そうでない場合は、開始できません。

また、/etc/hosts/に行き、127.0.0の行を削除します。1またはMASTER_IP変数をSpark構成で適切なホスト名に設定してください

出典

2017-01-11 13:30:41

+0

spark-shell - マスターのローカル（マスターで）、http：// master-ip：4040でSparkコンテキストWeb UIを利用できるというメッセージが表示されました...しかし、ブラウザを開いて何も表示していないとき...私の質問はスパーククラスターです。そして、スレーブ1とスレーブ2はクラスタの一部ですか？もしそうなら、私はどのように確認するのですか？そして最後にWebコンソールで何が間違っているのでしょうか？ –

+1

マスターと労働者のログを提供してください –

+0

編集を確認してください..私は問題がiptablesかもしれないと思う、クラスタは私が推測し始めなかった。 iptablesのために...しかし、私はまだ私がWebコンソールを見ることができない理由を理解することができません... –

0

問題はIPテーブルでした。他のほとんどのものは問題ありませんでした。だから私はちょうどhttps://wiki.debian.org/iptablesのIPテーブルを修正するための指示に従って、それは私のために働いた。私は8080、54310、50070、7077（いくつかのデフォルトはハープとスパークのインストールに多くの人が使用しています）を開きました...

出典

2017-01-11 18:36:25

関連する問題

 関連する問題