拓荒者001 - 简书

IP属地：云南

Flink端到端一致性调研
目录一、一致性定义 Flink通过插入barrier将流分为逻辑上的批，用来保存状态。因此一个checkpointid可以理解为一批数据的状态...

0.3 2436 0 1
KafkaProducer011
For each checkpoint we create new FlinkKafkaProducer so that new transac...

1322 0 0

Flink Local state VS External State
State Backend Support local state Local state backends maintain all stat...

653 0 0
确定性流处理总结
StreamScope和flamestream实现了确定性流处理。 1.实现思想这两篇论文中都指出需要实现确定性的处理，需要保证确定的执行逻...

615 0 0
Flamestream简单介绍
1. 核心思想通过把状态变成流的一部分，引入循环图，使得上一个item的状态可以作为下一个item的输入，使得有状态算子变成无状态算子。 be...

456 0 0
Data exchange between tasks

92 0 0