在kryoclasses中注册consumerrecord

plupiseo  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(218)

我的代码:

SparkConf conf = new SparkConf().setMaster("local[1]").setAppName("BadgeImageStreamJoin")
        .set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
        .registerKryoClasses((Class<ConsumerRecord>[]) Arrays.asList(ConsumerRecord.class).toArray());

我明白了

Exception in thread "main" java.lang.ClassCastException: class [Ljava.lang.Object; cannot be cast to class [Ljava.lang.Class; ([Ljava.lang.Object; and [Ljava.lang.Class; are in module java.base of loader 'bootstrap')

为什么registerkryoclasses抛出异常?
版本:

<java.version>11</java.version>
        <scala.version>2.12</scala.version>
        <spark.version>3.0.0</spark.version>

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题