Zeppelin 空指针异常

Question

我在我的 zeppelin 笔记本上写下了这段简单的代码

import org.apache.spark.sql.SQLContext
val sqlConext = new SQLContext(sc)
val df = sqlContext.read.format("csv").option("header", "true").load("hdfs:///user/admin/foo/2018.csv")
df.printSchema()

早些时候找不到spark-csv。所以我将它添加为 spark1 和 spark2 解释器的依赖项。但是当我运行这段代码时，我得到一个错误

java.lang.NullPointerException
    at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:38)
    at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:33)
    at org.apache.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:614)
    at org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:69)
    at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:493)
    at org.apache.zeppelin.scheduler.Job.run(Job.java:175)
    at org.apache.zeppelin.scheduler.FIFOScheduler.run(FIFOScheduler.java:139)

此文件只有 300 行。所以我不认为它会导致任何内存问题。我有一个 4 节点集群，那么如何确定更详细错误可能驻留的日志文件在哪里？

Answer 1

好的。我解决了。 Zeppelin 似乎使用 Scala 2.10 我已经为导致空指针错误的版本 2.11 添加了 Scala csv 的依赖项。

我去将我的依赖项更改为 2.10 并重新启动了解释器，现在它工作正常了。

Zeppelin 空指针异常

Zeppelin Null Pointer Exception

apache-spark

apache-zeppelin