Fault Tolerance

On the Internals of Stream Processing Systems

A look at the internal architecture (design and thread model) of modern stream processing systems using Apache Flink as an example.

Clonos: Consistent Causal Recovery for Highly-Available Streaming Dataflows

Stream processing lies in the backbone of modern businesses, being employed for mission critical applications such as real-time fraud detection, car-trip fare calculations, traffic management, and stock trading. Large-scale applications are executed …