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

}

关注公众号“大模型全栈程序员”回复“小程序”获取1000个小程序打包源码。更多免费资源在http://www.gitweixin.com/?p=2627

发表评论

邮箱地址不会被公开。 必填项已用*标注