在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

鍍金池/ 問答/Java  Scala/ scala調(diào)用java的序列化api報錯

scala調(diào)用java的序列化api報錯

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就有問題了呢？

回答
編輯回答
枕邊人

我在做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]))
  。。。。。。。

}

2017年1月29日 06:24