Powered by OpenAIRE graph
Found an issue? Give us feedback
image/svg+xml art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos Open Access logo, converted into svg, designed by PLoS. This version with transparent background. http://commons.wikimedia.org/wiki/File:Open_Access_logo_PLoS_white.svg art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos http://www.plos.org/ World Journal of Adv...arrow_drop_down
image/svg+xml art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos Open Access logo, converted into svg, designed by PLoS. This version with transparent background. http://commons.wikimedia.org/wiki/File:Open_Access_logo_PLoS_white.svg art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos http://www.plos.org/
World Journal of Advanced Research and Reviews
Article . 2025 . Peer-reviewed
Data sources: Crossref
image/svg+xml art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos Open Access logo, converted into svg, designed by PLoS. This version with transparent background. http://commons.wikimedia.org/wiki/File:Open_Access_logo_PLoS_white.svg art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos http://www.plos.org/
ZENODO
Article . 2025
License: CC BY
Data sources: ZENODO
ZENODO
Article . 2025
License: CC BY
Data sources: Datacite
ZENODO
Article . 2025
License: CC BY
Data sources: Datacite
versions View all 3 versions
addClaim

Enhancing checkpointing and state recovery for large-scale stream processing

Authors: Mukkath, Shakir Poolakkal;

Enhancing checkpointing and state recovery for large-scale stream processing

Abstract

As real-time applications demand ever-lower latencies and greater fault tolerance, traditional checkpointing mechanisms in distributed streaming systems face new performance bottlenecks. This article examines recent advancements in reducing checkpointing overhead while maintaining high availability, focusing on incremental state snapshots, asynchronous commit techniques, and log-based recovery models. It highlights the shift towards intelligent state management strategies, where adaptive checkpoint intervals and event-driven rollback mechanisms optimize resource utilization. The discussion delves into emerging storage backends that offer hybrid memory-disk approaches, enabling near-instantaneous state recovery without excessive write amplification. The article presents new perspectives on leveraging event sourcing as a state recovery alternative, where historical data streams are reprocessed dynamically to restore lost computation. Additionally, it explores targeted recovery techniques including partial state rollback, causality tracking, compensating events, and incremental recovery prioritization. These innovations collectively transform fault-tolerant stream processing by minimizing recovery scope while maintaining consistency guarantees. Through case studies and theoretical analysis, this work demonstrates how modern approaches significantly reduce recovery times and resource requirements, advancing the field of high-performance stream processing architectures suitable for mission-critical applications.

Keywords

Stream Processing, Incremental Checkpointing, Distributed Recovery, Fault Tolerance, Event Sourcing

  • BIP!
    Impact byBIP!
    selected citations
    These citations are derived from selected sources.
    This is an alternative to the "Influence" indicator, which also reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
    0
    popularity
    This indicator reflects the "current" impact/attention (the "hype") of an article in the research community at large, based on the underlying citation network.
    Average
    influence
    This indicator reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
    Average
    impulse
    This indicator reflects the initial momentum of an article directly after its publication, based on the underlying citation network.
    Average
Powered by OpenAIRE graph
Found an issue? Give us feedback
selected citations
These citations are derived from selected sources.
This is an alternative to the "Influence" indicator, which also reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
BIP!Citations provided by BIP!
popularity
This indicator reflects the "current" impact/attention (the "hype") of an article in the research community at large, based on the underlying citation network.
BIP!Popularity provided by BIP!
influence
This indicator reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
BIP!Influence provided by BIP!
impulse
This indicator reflects the initial momentum of an article directly after its publication, based on the underlying citation network.
BIP!Impulse provided by BIP!
0
Average
Average
Average
Green
gold