赞
踩
文章目录
End-to-End Exactly-Once-端到端的精确一次
Flink+Kafka的End-to-End Exactly-Once
Flink+Kafka实现End-to-End Exactly-Once
Flink+MySQL实现End-to-End Exactly-Once
Flink如何支持End-to-End Exactly-Once的?
Flink 在1.4.0 版本引入『exactly-once』并号称支持『End-to-End Exactly-Once』“端到端的精确一次”语义。
对于批处理,fault-tolerant(容错性)很容易做,失败只需要replay,就可以完美做到容错。
对于流处理,数据流本身是动态,没有所谓的开始或结束,虽然可以replay buffer的部分数据,但fault-tolerant做起来会复杂的多
流处理(有时称为事件处理)可以简单地描述为是对无界数据或事件的连续处理。流或事件处理应用程序可以或多或少地被描述为有向图,并且通常被描述为有向无环图(DAG)。在这样的图中,每个边表示数据或事件流,每个顶点表示运算符
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。