Jarvis: Large-scale Server Monitoring with Adaptive Near-data Processing
Atul Sandur, Chanho Park, Stavros Volos, Gul Agha, Myeongjae Jeon
Abstract
Rapid detection and mitigation of issues that impact performance and reliability are paramount for large-scale online services. For real-time detection of such issues, datacenter operators use a stream processor and analyze streams of monitoring data collected from servers (referred to as data source nodes) and their hosted services. The timely processing of incoming streams requires the network to transfer massive amounts of data, and significant compute resources to process it. These factors often create bottlenecks for stream analytics. To help overcome these bottlenecks, current monitoring systems employ near-data processing by either computing an optimal query partition based on a cost model or using model-agnostic heuristics. Optimal partitioning is computationally expensive, while model-agnostic heuristics are iterative and search over a large solution space. We combine these approaches by using model-agnostic heuristics to improve the partitioning solution from a model-based heuristic. Moreover, current systems use operator-level partitioning: if a data source does not have sufficient resources to execute an operator on all records, the operator is executed only on the stream processor. Instead, we perform data-level partitioning—i.e., we allow an operator to be executed both on a stream processor and data sources. We implement our algorithm in a system called Jarvis, which enables quick adaptation to dynamic resource conditions. Our evaluation on a diverse set of monitoring workloads suggests that Jarvis converges to a stable query partition within seconds of a change in node resource conditions. Compared to current partitioning strategies, Jarvis handles up to 75% more data sources while improving throughput in resource-constrained scenarios by 1.2-4.4×.
Ask about this paper
Your agent reads all of it.
Lune indexed this paper to the last equation, along with the top-tier papers that cite it. Ask a question and the answer quotes them.
Your agent calls
Luneget_paper_fulltext
Free to start. No credit card required.
Terminal
Install the CLIlune papers fulltext a52fccb0-2e83-428d-866d-6c8484647136Cited by top-tier papers2
- Efficient Placement of Decomposable Aggregation Functions for Stream Processing over Large Geo-Distributed TopologiesXenofon Chatziliadis, Eleni Tzirita Zacharatou, Alphan Eracar, Steffen Zeuch et al.VLDB 2024 · 16 citations
- Chameleon: Adaptive and Scalable Stream Processing Over Sensor SourcesDimitrios Giouroukis, Varun Pandey, Steffen Zeuch, Volker MarklICDE 2025
Builds on2
- OmniMon: Re-architecting Network Telemetry with Resource Efficiency and Full AccuracyQun Huang, Haifeng Sun, Patrick P. C. Lee, Wei Bai et al.SIGCOMM 2020 · 109 citations
- Gandalf: An Intelligent, End-To-End Analytics Service for Safe Deployment in Large-Scale Cloud InfrastructureZe Li, Qian Cheng, Ken Hsieh, Yingnong Dang et al.NSDI 2020 · 69 citations
Related papers
- SASPAR: Shared Adaptive Stream PartitioningJeyhun Karimov, Hans-Arno JacobsenICDE 2023 · 3 citations
- Enjima: A Resource-Adaptive Stream Processing SystemLasantha Fernando, Taebin Kim, Khuzaima Daudjee, Tilmann RablSIGMOD 2026
- SaSPartitioner: A Self-Adaptive Streaming Partitioner Using Deep Reinforcement LearningShenghao Gong, Liu Liu, Ziquan Fang, Yunjun Gao et al.ICDE 2026
- Generalizable Resource Allocation in Stream Processing via Deep Reinforcement LearningXiang Ni, Jing Li, Mo Yu, Wang Zhou et al.AAAI 2020 · 24 citations
- Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing SystemsAhmed S. Abdelhamid, Ahmed R. Mahmood, Anas Daghistani, Walid G. ArefSIGMOD 2020 · 19 citations
