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")

希望对您有所帮助！