Socket断开时基于DataStream应用的failover如何处理?
来源:5-1 DataStream API编程概述

D_Mario
2019-07-23
PK老师您好,
我想咨询一个问题,比如使用脑擦NC做基于Socket,使用DataStream做实时流的应用时,如果nc关闭或Socket断开了,flink的应用就出错退出了,这块在实际生产环境上是怎么处理的?是通过什么方式监控YARN上的某个作业挂了然后重启吗?监控和重启一般使用什么方式?
盼回复,谢谢.
写回答
1回答
-
nc仅仅是为了测试而已,生产上根本就不能用的,基本都是对接消息队列
062019-07-25
相似问题