paper-with-me

홈 › Papers

D3-GNN: Dynamic Distributed Dataflow for Streaming Graph Neural Networks

2024-09-10 · Rustam Guliyev, Aparajita Haldar, Hakan Ferhatosmanoglu

Graph Neural Network (GNN) models on streaming graphs entail algorithmic challenges to continuously capture its dynamic state, as well as systems challenges to optimize latency, memory, and throughput during both inference and training. We present D3-GNN, the first distributed, hybrid-parallel, streaming GNN system designed to handle real-time graph updates under online query setting. Our system addresses data management, algorithmic, and systems challenges, enabling continuous capturing of the dynamic state of the graph and updating node representations with fault-tolerance and optimal latency, load-balance, and throughput. D3-GNN utilizes streaming GNN aggregators and an unrolled, distributed computation graph architecture to handle cascading graph updates. To counteract data skew and neighborhood explosion issues, we introduce inter-layer and intra-layer windowed forward pass solutions. Experiments on large-scale graph streams demonstrate that D3-GNN achieves high efficiency and scalability. Compared to DGL, D3-GNN achieves a significant throughput improvement of about 76x for streaming workloads. The windowed enhancement further reduces running times by around 10x and message volumes by up to 15x at higher parallelism.

📄 PDF Abstract BibTeX arXiv:2409.09079

Code (0)

등록된 구현이 없습니다.

Tasks

Graph Neural Network

Similar Papers 제목 키워드 기반

Enel: Context-Aware Dynamic Scaling of Distributed Dataflow Jobs using Graph Propagation

2021-08-27 · Dominik Scheinert, Houkun Zhu, Lauritz Thamsen, Morgan K. Geldenhuys 외

Distributed dataflow systems like Spark and Flink enable the use of clusters for scalable data analytics. While runtime prediction models can be used to initially select appropriate cluster resources given target runtime…

Descriptive

Streaming Tensor Programs: A Streaming Abstraction for Dynamic Parallelism

2025-11-11 · Gina Sohn, Genghan Zhang, Konstantin Hossfeld, Jungwoo Kim 외 arxiv

Dynamic behaviors are becoming prevalent in tensor applications, like machine learning, where many widely used models contain data-dependent tensor shapes and control flow. However, the limited expressiveness of prior pr…

Pathway: a fast and flexible unified stream data processing framework for analytical and Machine Learning applications

2023-07-12 · Michal Bartoszkiewicz, Jan Chorowski, Adrian Kosowski, Jakub Kowalski 외

We present Pathway, a new unified data processing framework that can run workloads on both bounded and unbounded data streams. The framework was created with the original motivation of resolving challenges faced when ana…

Benchmarking

Incremental Community Detection in Distributed Dynamic Graph

2021-10-12 · Tariq Abughofa, Ahmed A. Harby, Haruna Isah, Farhana Zulkernine

Community detection is an important research topic in graph analytics that has a wide range of applications. A variety of static community detection algorithms and quality metrics were developed in the past few years. Ho…

ClusteringCommunity Detection

Recursive Function Definitions in Static Dataflow Graphs and their Implementation in TensorFlow

2024-10-26 · Kelly Kostopoulou, Angelos Charalambidis, Panos Rondogiannis

Modern machine learning systems represent their computations as dataflow graphs. The increasingly complex neural network architectures crave for more powerful yet efficient programming abstractions. In this paper we prop…