PDSP-Bench: A Benchmarking System for Parallel and Distributed Stream Processing

Fuente: arXiv
Saved in:
Bibliographic Details
Main Authors: Agnihotri, Pratyush, Koldehofe, Boris, Heinrich, Roman, Binnig, Carsten, Luthra, Manisha
Format: Preprint
Published: 2025
Subjects:
Online Access:
Tags: Add Tag
No Tags, Be the first to tag this record!
_version_ 1866909579967725568
author Agnihotri, Pratyush
Koldehofe, Boris
Heinrich, Roman
Binnig, Carsten
Luthra, Manisha
author_facet Agnihotri, Pratyush
Koldehofe, Boris
Heinrich, Roman
Binnig, Carsten
Luthra, Manisha
contents The paper introduces PDSP-Bench, a novel benchmarking system designed for a systematic understanding of performance of parallel stream processing in a distributed environment. Such an understanding is essential for determining how Stream Processing Systems (SPS) use operator parallelism and the available resources to process massive workloads of modern applications. Existing benchmarking systems focus on analyzing SPS using queries with sequential operator pipelines within a homogeneous centralized environment. Quite differently, PDSP-Bench emphasizes the aspects of parallel stream processing in a distributed heterogeneous environment and simultaneously allows the integration of machine learning models for SPS workloads. In our results, we benchmark a well-known SPS, Apache Flink, using parallel query structures derived from real-world applications and synthetic queries to show the capabilities of PDSP-Bench towards parallel stream processing. Moreover, we compare different learned cost models using generated SPS workloads on PDSP-Bench by showcasing their evaluations on model and training efficiency. We present key observations from our experiments using PDSP-Bench that highlight interesting trends given different query workloads, such as non-linearity and paradoxical effects of parallelism on the performance.
format Preprint
id arxiv_https___arxiv_org_abs_2504_10704
institution arXiv
publishDate 2025
record_format arxiv
spellingShingle PDSP-Bench: A Benchmarking System for Parallel and Distributed Stream Processing
Agnihotri, Pratyush
Koldehofe, Boris
Heinrich, Roman
Binnig, Carsten
Luthra, Manisha
Distributed, Parallel, and Cluster Computing
Databases
The paper introduces PDSP-Bench, a novel benchmarking system designed for a systematic understanding of performance of parallel stream processing in a distributed environment. Such an understanding is essential for determining how Stream Processing Systems (SPS) use operator parallelism and the available resources to process massive workloads of modern applications. Existing benchmarking systems focus on analyzing SPS using queries with sequential operator pipelines within a homogeneous centralized environment. Quite differently, PDSP-Bench emphasizes the aspects of parallel stream processing in a distributed heterogeneous environment and simultaneously allows the integration of machine learning models for SPS workloads. In our results, we benchmark a well-known SPS, Apache Flink, using parallel query structures derived from real-world applications and synthetic queries to show the capabilities of PDSP-Bench towards parallel stream processing. Moreover, we compare different learned cost models using generated SPS workloads on PDSP-Bench by showcasing their evaluations on model and training efficiency. We present key observations from our experiments using PDSP-Bench that highlight interesting trends given different query workloads, such as non-linearity and paradoxical effects of parallelism on the performance.
title PDSP-Bench: A Benchmarking System for Parallel and Distributed Stream Processing
topic Distributed, Parallel, and Cluster Computing
Databases
url https://arxiv.org/abs/2504.10704