面向Flink流处理框架的主动备份容错优化

刘广轩,黄山,胡佳丽,段晓东

Fault tolerant optimization of active backup for Flink stream processing framework

Guang-xuan LIU,Shan HUANG,Jia-li HU,Xiao-dong DUAN

图 3 正常情况下缓存队列的拦截作用

Fig.3 Interception function of Buffer Queue under normal circumstances