У меня есть тяжелая задача в zeppelin, так что, когда я запускаю этот абзац несколько раз, страница состояния Zeppelin /jobs возвращает ошибку HTTP 500 с OOM.
Каковы возможные причины этого?
Я запускаю клиентский режим с искрой на пряже.
У меня есть тяжелая задача в zeppelin, так что, когда я запускаю этот абзац несколько раз, страница состояния Zeppelin /jobs возвращает ошибку HTTP 500 с OOM.
Каковы возможные причины этого?
Я запускаю клиентский режим с искрой на пряже.
Может быть много причин для OOM в искровом интерпретаторе Zeppelin. Одной из возможных причин является
scala> case class A() defined class A scala> new A() res0: A = A() scala> new A() res1: A = A() scala> List(1, 2, 3, 4).map(x => x+1) // anonymous function
Вы можете увеличить память драйвера, установив spark.driver.memory
для искры в $SPARK_HOME/conf/spark-defaults.conf
localhost:8080/#/interpreter
, конфигурация интерпретатора искры)auto-restart interpreter on cron execution
.