Spark java.io.IOException：作业中未指定输入路径

Question

我有以下错误：

java.io.IOException: No input paths specified in job

当我执行以下行时：

val df = sqlContext.read.json("file://home/test.json")

有什么想法吗？

Answer 1

如果你想从本地加载数据，请使用

sqlContext.read.json("file:///home/shankar/test.json")

或者只是

sqlContext.read.json("/home/shankar/test.json")

会起作用

如果您想从 HDFS 加载文件，请使用

sqlContext.read.json("hdfs:///user/shankar/test.json")

希望这会有所帮助！