[1506.08603] Lightweight Asynchronous Snapshots for Distributed Dataflows
arXivLabs is a framework that allows collaborators to develop and share new arXiv features directly on our website. Both individuals and organizations that work with arXivLabs have embraced and accepted our values of openness, community, excellence, and user data privacy. arXiv is committed to these values and only works with partners that adhere to them. Have an idea for a project that will add value for arXiv's community? Learn more about arXivLabs. arXiv Operational Status Get status notifications via email or slack
View PDF HTML (experimental) Abstract:Distributed stateful stream processing enables the deployment and execution of large scale continuous computations in the cloud, targeting both low latency and high throughput. One of the most fundamental challenges of this paradigm is providing processing guarantees under potential failures. Existing approaches rely on periodic global state snapshots that can be used for failure recovery. Those approaches suffer from two main drawbacks. First, they often stall the overall computation which impacts ingestion. Second, they eagerly persist all records in…
saved by
related reading
- Hazelcast Jet: Low-latency Stream Processing at the 99.99th Percentilearxiv.org
- [1912.05036] RVSDG: An Intermediate Representation for Optimizing Compilersarxiv.org
- Keep the Tokens Flowing: Lessons from 16 Open-Source RL Librarieshuggingface.co
- [2508.12773] Online Ensemble Transformer for Accurate Cloud Workload Forecasting in Predictive Auto-Scalingarxiv.org
- [2403.06664] Smart-Infinity: Fast Large Language Model Training using Near-Storage Processing on a Real Systemarxiv.org
- [2512.19428] Attention Is Not What You Needarxiv.org
- DiffTaichi: Differentiable Programming for Physical Simulationarxiv.org
- Interactive Machine Learning: A State of the Art Reviewarxiv.org
- FTRANS: Energy-Efficient Acceleration of Transformers using FPGAarxiv.org
- [2509.14786] Pre-training under infinite computearxiv.org
- Async RL in Pure JAXdivyamakkar0.github.io
- Chain of Draft: Thinking Faster by Writing Lessarxiv.org