Jarvis: Large-scale Server Monitoring with Adaptive Near-data Processing
Atul Sandur, Chanho Park, Stavros Volos, Gul Agha, Myeongjae Jeon
摘要
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×.
问问这篇 Paper
智能体会读完全文。
Lune 把这篇 Paper 索引到了每一个公式,引用它的顶会 Paper 也一样。你提问,回答直接引用原文。
引用它的顶会 Paper2
- Efficient Placement of Decomposable Aggregation Functions for Stream Processing over Large Geo-Distributed TopologiesXenofon Chatziliadis, Eleni Tzirita Zacharatou, Alphan Eracar, Steffen Zeuch 等VLDB 2024 · 被引用 16 次
- Chameleon: Adaptive and Scalable Stream Processing Over Sensor SourcesDimitrios Giouroukis, Varun Pandey, Steffen Zeuch, Volker MarklICDE 2025
它引用的顶会 Paper2
- OmniMon: Re-architecting Network Telemetry with Resource Efficiency and Full AccuracyQun Huang, Haifeng Sun, Patrick P. C. Lee, Wei Bai 等SIGCOMM 2020 · 被引用 109 次
- Gandalf: An Intelligent, End-To-End Analytics Service for Safe Deployment in Large-Scale Cloud InfrastructureZe Li, Qian Cheng, Ken Hsieh, Yingnong Dang 等NSDI 2020 · 被引用 69 次
相关 Paper
- SASPAR: Shared Adaptive Stream PartitioningJeyhun Karimov, Hans-Arno JacobsenICDE 2023 · 被引用 3 次
- 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 等ICDE 2026
- Generalizable Resource Allocation in Stream Processing via Deep Reinforcement LearningXiang Ni, Jing Li, Mo Yu, Wang Zhou 等AAAI 2020 · 被引用 24 次
- Prompt: Dynamic Data-Partitioning for Distributed Micro-batch Stream Processing SystemsAhmed S. Abdelhamid, Ahmed R. Mahmood, Anas Daghistani, Walid G. ArefSIGMOD 2020 · 被引用 19 次
