storm java.io.NotSerializableException
今天编写一个storm的topology,bolt的逻辑跟之前的类似。
为了减少重复代码,我建了个抽象基类,存放bolt的公共逻辑,设计了几个abstract方法,不同的逻辑部分由子类实现。
基类日志定义如下:
private static final Logger LOG = LoggerFactory.getLogger(AbstractXxxBolt.class);
Logger是项目封装的,用于ELK的对象,考虑到子类可能用到,我把它的static去掉,AbstractXxxBolt.class改成了getClass();
本机启动topology报错:storm java.io.NotSerializableException Logger;
改回static后,启动正常;
子类中,有引用其它工程的dubbo服务接口,开始写在构造函数中初始化的,
private XxxService xxxService; SubClass() {
super();
xxxService = XxxUtil.getBean(XxxService.class);
}
本机启动topology报错:storm NotSerializableException com.alibaba.dubbo.common.bytecode.proxy0
解决方法:
将子类构造函数中的赋值去掉,抽象一个doPrepare()方法,在基类的prepare()方法中调用
子类实现doPrepare(),在其中xxxService = XxxUtil.getBean(XxxService.class);
-----------------------------------------------------------------------------------------------------------------------------
The supervisor instantiates the bolts, sends them to the workers, and then calls prepare() on all of them. Therefore, anything
that isn't serializable that is instantiated before prepare() causes this process to fail.
-----------------------------------------------------------------------------------------------------------------------------
参考:
https://blog.csdn.net/wanghai__/article/details/8997895
最新文章
- .NET 基础一步步一幕幕[方法、结构、枚举]
- jquery中css获取颜色属性
- mongodb-索引
- [CareerCup] 15.5 Denormalization 逆规范化
- 关于RESTFUL API 安全认证方式的一些总结
- fafu 1568 Matrix(二分匹配+二分)
- WTIR Updating Page
- 淘宝API调用 申请 获取session key
- Hibernate之Hibernate的下载与安装
- 3、Android构建仪表测试
- Tomcat使用shutdown.bat关闭会将其他Tomcat关掉的问题
- 【Linux常用工具】
- leetcode-递增的三元子序列
- Xamarin iOS教程之使用按钮接接收用户输入
- SQL Server优化50法(转载)
- oracle 视图views
- ios开发之--使用toolbar调整item之间的间隔
- win10下安装MySQL5.7.20
- 解决图片浮动调节不了的问题(使用vertical-align属性)
- TCP粘包处理