clarification on backpressure metrics in Apache Flink Dashboard

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

clarification on backpressure metrics in Apache Flink Dashboard

Marco Villalobos-2
given:

[source] -> [operator 1] -> [operator 2] -> [sink].

If within the dashboard, operator 1 shows that it has backpressure, does that mean I need to improve the performance of operator 2 in order to alleviate backpressureĀ upon operator 1?



Screen Shot 2021-02-10 at 7.49.50 PM.png (78K) Download Attachment
Reply | Threaded
Open this post in threaded view
|

Re: clarification on backpressure metrics in Apache Flink Dashboard

Chesnay Schepler
Yes. Unless operator 2 is also back-pressured of course, then you should
take a look at the sink.

On 2/11/2021 4:50 AM, Marco Villalobos wrote:
> given:
>
> [source] -> [operator 1] -> [operator 2] -> [sink].
>
> If within the dashboard, operator 1 shows that it has backpressure,
> does that mean I need to improve the performance of operator 2 in
> order to alleviate backpressureĀ upon operator 1?
>
>