下面的spark代码用于创建datapipeline。

package Test
import org.apache.log4j.{Level, Logger}
import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._
import org.apache.spark.sql.expressions.Window
object myjson {def main(args: Array[String]): Unit = {
  val spark = SparkSession.builder()
    .appName("Readfile")
    .config("spark.driver.memory", "2g")
    .master("local[*]")
    //.enableHiveSupport()
    .getOrCreate()
  import spark.implicits._
  val df = spark.read.option("multiLine", true).json("D:mypathTest/myfile.json")
  df.printSchema()
  val newdf = ds.withColumn("upTime",regexp_replace(col("upTime"),"[a-zA-Z]","")).
}
}

有没有办法在scala中创建日志记录和警报机制。或者如何实现错误处理，比如如果文件不在路径错误中。请帮帮我。