Apache spark scala异常处理

import org.apache.spark.SparkConf
import org.apache.spark.SparkContext

object SparkExceptionHandling {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("SparkExceptionHandling").setMaster("local")
    val sc = new SparkContext(conf)

    try {
      // 可能会抛出异常的代码
      val data = sc.textFile("input.txt")
      val count = data.count()
      println("Total count: " + count)
    } catch {
      case ex: Exception => {
        // 捕获并处理异常
        println("Exception occurred: " + ex.getMessage)
      }
    } finally {
      // 无论是否发生异常都会执行的代码
      sc.stop()
    }
  }
}