Zeppelin не работает с внешней искрой - не может получить или обновить прогресс

Я установил Zeppelin 0.6.2 и пытаюсь заставить его работать с внешним искровым кластером (2.0.1).

У меня есть настройки переводчика следующим образом:

args
master 121.201.~~.1~~:8080 spark.app.name Zeppelin spark.cores.max spark.executor.memory
zeppelin.R.cmd R zeppelin.R.image.width

Тем не менее, когда я пробую искровой код, я получаю ошибки:

ИНФОРМАЦИЯ [2016-12-16 15:30:28,236] ({pool-1-thread-16} NotebookServer.java[afterStatusChange]:1150) - Задание 20161215-231306_1684928197 завершено ИНФОРМАЦИЯ [2016-12-16 15:30:28,313] ({pool-1-thread-16} SchedulerFactory.java[jobFinished]:137) - задание абзаца_1481814786923_-1347555476 завершено планировщиком org.apache.zeppelin.interpreter.remote.RemoteInterpretershared_session140539475-16 15ROR:30,203] ({Thread-83} JobProgressPoller.java[run]:54) - Не удается получить или обновить ход выполнения org.apache.zeppelin.interpreter.InterpreterException: org.apache.thrift.transport.TTransportException в org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getProgress(RemoteInterpreter.java:373) в org.apache.zeppelin.interpreter.LazyOpenInterpreter.getProgress(LazyOpenInterpreter.java:111) в org.apache.zeppegraph.notej.Pargraph:237) at org.apache.zeppelin.scheduler.JobProgressPoller.run(JobProgressPoller.java:51) Причина: org.apache.thrift.transport.TTransportException at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) в org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) в org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429) в org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318) в org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219) в org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69) в org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.recv_getProgress(RemoteInterpreterService.java:296) в org.apache.zeppelin.interpreerteth.tm (RemoteInterpreterService.java:281) в org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getProgress(RemoteInterpreter.java:370) ... еще 3

0 ответов

Другие вопросы по тегам