StreamTask with Mailbox.pdf Our motivation behind this proposal is to simplify the threading model of stream tasks with a mailbox-based approach (similar to execution model commo
QueryableStateFLINK3779.pdf Flink QueryableState设计文档(FLINK-3779) Flink offers state abstractions for user functions1 in order to guarantee fault-tolerant processing of streams. U
分布式一致性快照算法.pdf Distributed Snapshots: Determining Global States of Distributed Systems 分布式一致性算法论文(Chandy-Lamport算法)