scala调用java的序列化api报错

0 0 java scala
八零末愤青
八零末愤青

声望值:133 0人

2018-07-10 13:04:44 提问

关注 0关注

收藏 0收藏, 197浏览

clipboard.png

报错如下
Exception in thread "main" java.lang.IllegalStateException: Reading from a byte array threw an IOException (should never happen).

at com.yixue.xdatam.ConvertUtil.unserialize(ConvertUtil.java:226)

有点想不通的是,其他之前写的javaAPI拿到scala下都可以用,为什么序列化api java上没问题,scala就有问题了呢?

请先 登录 后评论

1个回答

  • l梁上君子141声望 2018-10-15 16:00

    我在做Kafka和sparkstreaming中也遇到过序列化问题。 你用我这种写法看看有没有问题。使用RunTimeSchema 获取schema def executeByScan(rdd: RDD[(Array[Byte], Array[Byte])], path: String): Unit = { val resultRdd = rdd.map(row => { val result: KafkaMessage = new KafkaMessage ProtostuffIOUtil.mergeFrom(row._2, result, RuntimeSchema.getSchema(classOf[KafkaMessage])) 。。。。。。。 }
    请先 登录 后评论

注册新账号

悬赏追问
10
  • 10
  • 20
  • 50
  • 100
  • 200
  • 输入数值
发布追问