-
0 votesanswersviews
Kryo在读取时导致缓冲区下溢异常
我正在序列化: private byte[] serialize() { KryoPool pool = new KryoPool.Builder(factory).softReferences().build(); Kryo kryo = pool.borrow(); Output output = new Output(0, 1024); kryo.writeC... -
1 votesanswersviews
使用Scala的Kryo的HazelcastSerializationException
我正在使用kryo与Scala 2.11.1和Hzaelcast 3.5进行序列化我试图将我的数据放入hazelcast Map 但我得到了KryoException 这是我的模特课 @SerialVersionUID(1) case class User( id : Int ,name : String, userType : UserType /*UserType is Enu... -
1 votesanswersviews
来自 kafka 主题的 Java bean 的 Storm Kafkaspout KryoSerialization 问题
嗨,我是 Storm 和 Kafka 的新手。我正在使用 storm 1.0.1 和 kafka 0.10.0 我们有一个 kafkaspout,可以从 kafka 主题接收 java bean。我花了几个小时来寻找合适的方法。找到一些有用的文章,但迄今为止没有一种方法对我有用。 以下是我的代码: StormTopology: public class StormTopology { publi... -
3 votesanswersviews
使用Play2和Scala 2.11.1在twitter / chill中反序列化异常
我正在使用Scala 2.11.1和Hazelcast 3.5以及twitter-chill进行序列化 我在Server(Sbt项目)和客户端(Play2项目)上都有一个User和Serializer UserSerializer类 我在Hazelcast中存储User对象,我的序列化程序在服务器上工作正常,但同一序列化程序的读取方法给了我异常 这是我的序列化器 // takes the byte... -
4 votesanswersviews
Chill-kryo的例外情况
我试图从这个link运行Chill-Scala的示例代码 我有两个虚拟案例类 一个是用户 @SerialVersionUID(1) case class User(name :String, age : Int) extends Serializable 另一个是学生 @SerialVersionUID(2) case class Student(sub : String , id : Int ...