Я пытаюсь назначить три ядра на исполнителя для приложения Spark, и иногда я получаю следующую ошибку в исполнителях:
ОШИБКА [10-02-2018 19: 25: 00,228][_CI =] [_P =] [_F =] [_EC =] [_ED =] [_PI =] [_PPI =] [_B =] [_E =] [_S =] org.apache.spark.network.shuffle.RetringBlockFetcher - Исключительная ситуация при начале выборки из 1 ожидающих блоков (после 2 повторных попыток)228) [трассировка стека продолжается] Причина: io.netty.channel.AbstractChannel $ AnnotatedConnectException: соединение отклонено: /127.0.0.1:36480 в sun.nio.ch.SocketChannelImpl.checkConnect (собственный метод)
[stacktraceпродолжение]
Это как если бы исполнитель пытался найти что-то (мастер? драйвер?) в localhost ...
Спасибо,