Size: a a a

2018 October 30

AA

Anton Alekseev in Moscow Spark
Евгений Санников
Веб-морде лучше не верить, а залезть физически на сервер и посмотреть
я на нём, щас вот засабмитил. Вообще не ранилось, повисело в accepted и закрашилось. В консоли ярн не видит логов для этого апп.
источник

ЕС

Евгений Санников... in Moscow Spark
Anton Alekseev
После того как переходит в статус Accepted из Running логи уже не может найти. так и должно быть?
Или вы выполяете команду в момент передачи логов на head ноду класетра, на которой агрегируются логи. Тоже возможно, но очень маловероятно
источник

ЕС

Евгений Санников... in Moscow Spark
Anton Alekseev
я на нём, щас вот засабмитил. Вообще не ранилось, повисело в accepted и закрашилось. В консоли ярн не видит логов для этого апп.
посмотрите логи для контейнера *001 - это контейнер драйвера
источник

AA

Anton Alekseev in Moscow Spark
Евгений Санников
посмотрите логи для контейнера *001 - это контейнер драйвера
смотрю через yarn logs -containerId <Container ID>, возвращает что никаких логов найти не может, ну а в соседнем окне апп висит в статусе accepted.
источник

ЕС

Евгений Санников... in Moscow Spark
А физически можете зайти в папку где хранятся аггрегированные логи на head ноде?
источник

AA

Anton Alekseev in Moscow Spark
Евгений Санников
А физически можете зайти в папку где хранятся аггрегированные логи на head ноде?
Зашёл, папка отстутствует, апп висит в accepted. Тут вообще в разнобой все, что-то залогировалось для других же апп нет папок. (номера по порядку, но остутствуют некоторые)
источник

AA

Anton Alekseev in Moscow Spark
Кстати между делом пару раз отработало корректно, сейчас опять начинает залипать в accepted
источник

ЕС

Евгений Санников... in Moscow Spark
Аггрегация запускается после завершения работы. Анализируй те, что завершились failed or done
источник

AA

Anton Alekseev in Moscow Spark
Евгений Санников
Аггрегация запускается после завершения работы. Анализируй те, что завершились failed or done
Завершилось с фейлом, в yarn application -list пусто, папочка в логах так и не появилась.😢
источник

ЕС

Евгений Санников... in Moscow Spark
Или на драйвер и смотри там логи
источник

AA

Anton Alekseev in Moscow Spark
Евгений Санников
Или на драйвер и смотри там логи
Драйвер - это воркеры?
источник

ЕС

Евгений Санников... in Moscow Spark
Одна из воркер нод выбирается драйвером. адрес драйвера можешь посмотреть в консоли или веб морде yarn
источник

AA

Anton Alekseev in Moscow Spark
Евгений Санников
Одна из воркер нод выбирается драйвером. адрес драйвера можешь посмотреть в консоли или веб морде yarn
у меня 2 машинки (мастер и воркер), ни там ни там логи не появились.
источник

AA

Anton Alekseev in Moscow Spark
вот теперь опять, каждый запуск отрабатывает нормально, и логи валятся и заканчивается succeeded.
источник

AA

Anton Alekseev in Moscow Spark
Старые логи падали с ошибкой - неудается стартовать контейнер, после чего разрыв соединения.
источник
2018 November 01

SK

Sergey Karpiy in Moscow Spark
Всем привет, кто подскажет, делаю кондишн джоин в спарке по координатам, условно abs(x1-x2) <1, данных относительно немного, так что обе таблицы в память влезают, но в итоге по производительности пока хуже чем локально, судя по всему таски распределяются на несколько экзекьюторов, а не размазываются по всем
источник

SK

Sergey Karpiy in Moscow Spark
Есть бест практис для таких джоинов, тип x - float
источник

SK

Sergey Karpiy in Moscow Spark
?
источник

AC

Anton Chern in Moscow Spark
repartition пробовал?
источник

SK

Sergey Karpiy in Moscow Spark
Пока нет, у меня двойной джоин, по x, y
источник