当前位置： 移动技术网 > 移动技术>移动开发>IOS > 异常被抛出（不被catch）会导致flink任务挂掉

异常被抛出（不被catch）会导致flink任务挂掉

2020年07月17日  | 移动技术网移动技术  | 我要评论

背景：

实时效果数据中map的每条数据处理都需要一个单例的对象，这个单例对象的初始化在open方法中

在map每次计算前都会判断此单例对象是否存在，如果不存在希望flink任务挂掉

 

思路：

如果发现对象为null，抛出异常，不catch

空指针异常是运行时异常的子集，抛出哪个都可以，只是空指针异常语义更明确

 

代码如下

 

线上测试

线上部署之后，在task日志，jobManager日志，Exception日志中均发现了空指针异常

flink任务在反复重试几次之后失败（这需要几分钟时间），符合预期

本文地址：https://blog.csdn.net/matrix_google/article/details/107389497

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网