丷梅乐桃桃丶

0 声望

这家伙太懒，什么都没留下

个人动态

丷梅乐桃桃丶在 Job aborted due to stage failure: Task 0.0 had a not serializable result: org.apache.kafka.clients.consumer.ConsumerRecord 发表评论：
可以试试val sparkConf = new SparkConf().set("spark.serializer", "org.apache.spark.serializer.KryoSerializer")

6年前