私はSpark ClusterをHDFSの上にYARNモードで実行しています。私は2つのコアと2gのメモリを持つ1人のワーカーを立ち上げました。その後、私は3コアで1人のエグゼキュータの動的構成で仕事を提出しました。それでも、私の仕事は動くことができます。作業者が起動されたコアの数とエグゼキュータのために要求されたコアの数の違いを説明することができます。エグゼクティブが労働者の中で働いているので、労働者が利用できるものよりも多くの資源を得ることができないので、私の理解はありました。スパークワーカーとエグゼクティブコア
0
A
答えて
0
yarn-site.xmlのパラメータyarn.nodemanager.resource.cpu-vcoresを確認します。
yarn.nodemanager.resource.cpu-vcoresは、各ノードのコンテナで使用されるコアの最大合計を制御します。
0
- > Sparkはワーカーノード内でn個のエグゼキュータを起動します。 - > Sparkは、sparkクラスタへのアプリケーション提出時にエグゼキュータを起動するためのコア数とexecutor-memoryパラメータを使用します。 - >スパーク・サブミットでは、ワーカー・ノードのコア数を指定することはできません。
関連する問題
- 1. スパークワーカーがスローFileNotFoundException一時シャッフルファイルの場合
- 2. スパークワーカーを手動で停止する
- 3. スパークワーカーの1人が働いていません
- 4. ドライバがシャットダウンを指示した後にスパークワーカーが停止する
- 5. スパークワーカーがマスターに接続していません
- 6. スパークワーカーがすべて起動しているわけではありません:SPARK_WORKER_INSTANCES
- 7. 32GB以上のメモリを持つスパークワーカーに致命的なエラーが発生しました
- 8. スパークはエラーを出します(最初の仕事は受け入れられていません)
- 9. ハーフープ(シングルおよびマルチ)ノード、spark-masterおよびspark-workerとは何ですか?
- 10. スパークストリーミングジョブで一度JDBC接続を開始
- 11. Apacheのスパークスタンドアロン変更エグゼキュータのユーザー名
- 12. 差異 - と - と 'と'または 'と'と
- 13. Rancherと牛とRancherとKubernetesとStandalone Kubernetes
- 14. Toxとlibとlib64とサイトパッケージ
- 15. と#とのキャスティング
- 16. TabHostとAndroidと
- 17. stringformatとキーと_
- 18. $ whereと$と
- 19. lxmlとCDATAと&
- 20. ORとSUMIFSと
- 21. | =とdivmodとは
- 22. JavaとFlexとFlerryとの間のメッセージ
- 23. jstat:OGCとOCとの違い、PGCとPC
- 24. jQueryとjQuery infinitescrollとjQueryとのDrupal.attachBehaviours
- 25. Kafka Stream:KTableとGlobalKTableとKStream - leftJoin()とouterJoin()
- 26. MobileNetとSqueezeNetとResNet50 vs Inception v3とVGG16
- 27. BPとワークフローとアクティビティとの関係
- 28. CとロードOBJファイルとバグ++とOpenGL
- 29. Node-PerfectAPIとRestify.jsとExpressJSとNode-APIServer
- 30. Kafka max.request.sizeとbuffer.memoryとsend.buffer.bytesとの比較