Spark CSV数据框加载，找不到文件

【问题标题】：Spark CSV Dataframe Load ,File not foundSpark CSV数据框加载，找不到文件
【发布时间】：2018-03-08 14:14:20
【问题描述】：

如果在 spark csv 读取的给定位置找不到我的文件，如何捕获异常？

try {
    val df = sqlCxt.read.format("csv")
    .option("delimiter", "|")
    .load("C:/Users/swapnil.shirke/Downloads/dataset/u.item");

}
catch {

case ex: FileNotFoundException => {
println(" file missing exception")
}
case ex: Exception => ex.printStackTrace()
}

假设 try catch 条件不起作用。

【问题讨论】：

您是否检查了您的执行程序日志是否打印了该消息？

标签： csv apache-spark dataframe

【解决方案1】：

在scala中，如果文件路径不正确则异常为org.apache.spark.sql.AnalysisException: Path does not exist: ....，所以正确的方法是

try {
  val df = sqlCxt.read.format("csv")
    .option("delimiter", "|")
    .load("/Users/swapnil.shirke/Downloads/dataset/u.item");

}
catch {
  case ex: AnalysisException => {
    println(" file missing exception")
  }
  case ex: Exception => ex.printStackTrace()
}

希望回答对你有帮助

【讨论】：