背景：
实时效果数据中map的每条数据处理都需要一个单例的对象，这个单例对象的初始化在open方法中
在map每次计算前都会判断此单例对象是否存在，如果不存在希望flink任务挂掉
思路：
如果发现对象为null，抛出异常，不catch
空指针异常是运行时异常的子集，抛出哪个都可以，只是空指针异常语义更明确
代码如下
线上测试
线上部署之后，在task日志，jobManager日志，Exception日志中均发现了空指针异常
flink任务在反复重试几次之后失败（这需要几分钟时间），符合预期
相关文章：