AWSGlueScalaSparkJob失败-org.apache.spark.util.collection.CompactBuffer[]未在Kryo中注册。
创始人
2024-09-25 16:30:09
0

由于AWS Glue中使用的Spark版本可能与本地环境中使用的Spark版本不同,因此需要在Glue Job中注册必要的序列化类。在本例中,未在Kryo中注册org.apache.spark.util.collection.CompactBuffer类。

解决此问题的方法是在AWS Glue Job中注册类。可以使用以下代码示例:

import com.esotericsoftware.kryo.Kryo
import org.apache.spark.serializer.KryoRegistrator
import org.apache.spark.util.collection.CompactBuffer

class MyRegistrator extends KryoRegistrator {
  override def registerClasses(kryo: Kryo) {
    kryo.register(classOf[CompactBuffer[_]])
  }
}

val spark: SparkSession = SparkSession.builder
  .appName("MyApp")
  .config("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
  .config("spark.kryo.registrator", classOf[MyRegistrator].getName)
  .getOrCreate()
  
// 在这里执行Glue Job代码

在这段代码中,我们创建了一个kryo注册器类MyRegistrator,并在其中注册了CompactBuffer类。我们将该注册器类传递给SparkSession对象,以确保正确注册了所有所需的类。请在执行Glue Job代码之前添加此代码段。

相关内容

热门资讯

2分钟辅助!wepoker手机... 2分钟辅助!wepoker手机助手,pokermaster辅助器,法子教程(有挂工具)亲,关键说明,...
第五分钟辅助!pokemmo辅... 第五分钟辅助!pokemmo辅助器手机版下载,拱趴大菠萝怎么开挂,教材教程(有挂功能)1、玩家可以在...
五分钟辅助!hhpoker是真... 五分钟辅助!hhpoker是真的还是假的,哈糖大菠萝有挂吗,积累教程(有挂详情)1、每一步都需要思考...
八分钟辅助!epoker免费透... 八分钟辅助!epoker免费透视脚本,hhpoker辅助器,手段教程(有挂透明挂)1、每一步都需要思...
第二分钟辅助!we-poker... 第二分钟辅助!we-poker正规吗,hhpoker一直输有挂吗,总结教程(的确有挂)1、hhpok...
八分钟辅助!pokermast... 八分钟辅助!pokermaster辅助器,wpk透视插件,策略教程(有挂方法)1、pokermast...
2分钟辅助!拱趴大菠萝有什么挂... 2分钟辅助!拱趴大菠萝有什么挂,hhpoker必备开挂,烘培教程(有挂秘籍)1、拱趴大菠萝有什么挂公...
4分钟辅助!wepoker软件... 4分钟辅助!wepoker软件靠谱么,wepoker免费脚本,法门教程(有挂详细)1、用户打开应用后...
第九分钟辅助!wepoker有... 第九分钟辅助!wepoker有脚本吗,wepoker透视脚本免费app,手筋教程(有挂方式)1、we...
第九分钟辅助!德普之星私人局辅... 第九分钟辅助!德普之星私人局辅助器,德普之星辅助工具如何打开,步骤教程(有挂猫腻)1、德普之星辅助工...