org.apache.spark.SparkException: Task not serializable暴力解决方法
在调用另一个类时,出现错误org.apache.spark.SparkException: Task not serializable,于是在出现这个类继承java.io.Serializable。还可以都继承下面这个公共类:
trait AppConf extends java.io.Serializable{
val spark = SparkSession.builder().appName("kline").master("local[*]").getOrCreate(); //为读取的数据创建schema
}