Socket断开时基于DataStream应用的failover如何处理?

来源:5-1 DataStream API编程概述

D_Mario

2019-07-23

PK老师您好,
我想咨询一个问题,比如使用脑擦NC做基于Socket,使用DataStream做实时流的应用时,如果nc关闭或Socket断开了,flink的应用就出错退出了,这块在实际生产环境上是怎么处理的?是通过什么方式监控YARN上的某个作业挂了然后重启吗?监控和重启一般使用什么方式?
盼回复,谢谢.

写回答

1回答

Michael_PK

2019-07-23

nc仅仅是为了测试而已,生产上根本就不能用的,基本都是对接消息队列

0
6
D_Mario
非常感谢!
2019-07-25
共6条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程