星火产生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") 

Hope t他的帮助！