0

我已经安装了 Zeppelin 0.6.2 并试图让它与外部 spark 集群 (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

但是,当我尝试使用 spark 代码时,出现错误:

INFO [2016-12-16 15:30:28,236] ({pool-1-thread-16} NotebookServer.java[afterStatusChange]:1150) - 作业 20161215-231306_1684928197 已完成 INFO [2016-12-16 15:30: 28,313] ({pool-1-thread-16} SchedulerFactory.java[jobFinished]:137) - Job paragraph_1481814786923_-1347555476 由调度程序 org.apache.zeppelin.interpreter.remote.RemoteInterpretershared_session1405394754 完成 错误 [2016-12-16 15:30 :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) at org.apache.zeppelin.interpreter.LazyOpenInterpreter.getProgress(LazyOpenInterpreter.java:111) at org.apache.zeppelin.notebook.Paragraph.progress(Paragraph.java:237) at org.apache.zeppelin.scheduler.JobProgressPoller.run(JobProgressPoller.java:51) 引起: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. org.apache.zeppelin.interpreter.thrift 上的 apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.recv_getProgress(RemoteInterpreterService.java:296)。RemoteInterpreterService$Client.getProgress(RemoteInterpreterService.java:281) at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getProgress(RemoteInterpreter.java:370) ... 还有 3 个

4

0 回答 0