Я попытался запустить задание на своем кластере Spark с помощью EMR. Кластер состоит из одного ведущего и двух ведомых узлов, и каждый узел (ведущий или ведомый узел) имеет 32 ядра. Задание использовало «Добавить шаг» через консоль, конфигурация указана ниже:
sparkConf.setMaster ("локальный [24]"). set ("spark.executor.memory", "40g") .set ("spark.driver.memory", "40g");
Затем я заметил, что два ведомых устройства не работают (загрузка ЦП близка к 0), усердно работал только мастер. Как мне исправить эту проблему и заставить рабов работать?
Спасибо!