星火產生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他的幫助！