异常被抛出(不被catch)会导致flink任务挂掉

背景: 实时效果数据中map的每条数据处理都需要一个单例的对象,这个单例对象的初始化在open方法中 在map每次计算前都会判断此单例对象是否存在,如果不存在希望flink任务挂掉   思路: 如果发现对象为null,抛出异常,不catch 空指针异常是运行时异常的子集,抛出哪个都可以,只是空指针异常语义更明确   代码如下   线上测试 线上部署之后,在task日志,jobManager日志,E
相关文章
相关标签/搜索