此连接器可访问由Apache Kafka提供的事件流。 Flink提供特殊的Kafka连接器,用于从/到Kafka主题读取和写入数据。 Flink Kafka Consumer集成了Flink的检查点机制,以提供一次性处…
标签:检查点
Java Spark 简单示例(九) CheckPoint 检查点使用
大数据学习交流微信群 Spark 采用Lineage(书里叫血统)和CheckPoint(检查点)两种方式来解决分布式数据集中的容错问题。Lineage本质上类似于数据库的重做日志(redo log),只不过这个日志粒度…