Trident Storm升级Jstorm,Config注册序列化类报错

14 views
Skip to first unread message

L Robin

unread,
Mar 28, 2017, 3:47:39 AM3/28/17
to jstorm
哈喽,
项目原始是基于storm1.x写的,现在想使用jstorm,环境已经升级到了最新的2.2.1,但是在Topology中注册序列化类的时候提示方法使用错误,但查看了源码貌似也是这样使用的,麻烦哪位帮忙看看。






StreamUpdater类定义:
public class StreamUpdater extends BaseStateUpdater<StreamState>
StreamSerializer类定义:
public class StreamSerializer extends Serializer<StreamData>
源码registerSerialization方法:
public void registerSerialization(Class klass, Class<? extends Serializer> serializerClass) {
registerSerialization(this, klass, serializerClass);
}

源码中Serializer类和StreamSerializer 继承的Serializer都引用自
package com.esotericsoftware.kryo;包中的public abstract class Serializer<T>

个人感觉两个参数都无异常,但就是一直提示错误,请问哪位遇到过,还望告知,多谢
Reply all
Reply to author
Forward
0 new messages