我試着在使用EMR的Spark羣集上運行一個作業。該集羣有一個主站和兩個從站,每個節點(主站或從站節點)有32個內核。該作業通過控制檯使用「添加步驟」,配置設置如下:如何使用EMR使從屬節點適用於Spark羣集?
sparkConf.setMaster(「local [24]」).set(「spark.executor.memory」,「40g」) 。 set(「spark.driver.memory」,「40g」);
然後我注意到兩個從站不工作(CPU使用率接近0),只有主人正在努力工作。我如何解決這個問題,並使奴隸工作?
謝謝!
嗨,我需要設置sparkConf.setMaster(「yarn-cluster」)嗎?或者不要設置任何東西,並且./bin/spark-submit - 主紗線集羣會照顧它?謝謝! – Edamame 2015-02-12 17:33:19
請勿使用sparkConf.setMaster。使用 - 主管紗羣參數 – pzecevic 2015-02-13 09:46:41