具体报错
在conf中添加配置
val sparkConf: SparkConf = new SparkConf().setMaster("local[*]").setAppName("OrderWideApp") .set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
上一篇 不同环境相同配置项的内容如何diff差异?
下一篇 Linux常用命令
版权所有 ©2023-2025 051e.com
ICP备案号:京ICP备12030808号