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

Question

如果在 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 条件无效。

Answer 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()
}

希望回答对你有帮助