Skip to content

[Task]: Fix performance degradation for Flink with side inputs #23998

@JozoVilcek

Description

@JozoVilcek

What needs to happen?

When streaming job executed on FlinkRunner started to use side-inputs, we noticed big performance impact on throughput. This is observed on v2.33.0. Example of hot stack trace: hot-stack.txt

Issue Priority

Priority: 2

Issue Component

Component: runner-flink

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions