我的代码:
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>
暂无答案!
目前还没有任何答案,快来回答吧!