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?
Re: clarification on backpressure metrics in Apache Flink Dashboard
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?
>
>