SparkSession.read().csv()無法定位本地文件的問題


原因是spark有兩個文件頭

  [file://]代表本地

  [hdfs://]代表hdfs路徑

如果路徑沒有文件頭,spark會將該路徑默認添加上"hdfs://"

所以如果要訪問本地csv文件,需要確保路徑前面有"file://"

//java代碼,告訴spark這是本地文件
"file:///" + url

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM