This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new b808f91 [FLINK-22489][webui] Fix displaying individual subtasks
backpressure-level
b808f91 is described below
commit b808f9199a1eaa030513bbc5c73722055cbd9756
Author: Piotr Nowojski <[email protected]>
AuthorDate: Tue Apr 27 15:44:57 2021 +0200
[FLINK-22489][webui] Fix displaying individual subtasks backpressure-level
Previously (incorrectly) backpressure-level from the whole task was being
displayed for
each of the subtasks.
---
.../backpressure/job-overview-drawer-backpressure.component.html | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpressure.component.html
b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpressure.component.html
index 41377e1..6b8b2fc 100644
---
a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpressure.component.html
+++
b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpressure.component.html
@@ -61,7 +61,7 @@
<td>{{ subtask['subtask'] }}</td>
<td>{{ this.prettyPrint(subtask['ratio']) }} / {{
this.prettyPrint(subtask['idleRatio']) }} / {{
this.prettyPrint(subtask['busyRatio']) }}</td>
<td>
- <flink-backpressure-badge
[state]="backpressure['backpressure-level']"></flink-backpressure-badge>
+ <flink-backpressure-badge
[state]="subtask['backpressure-level']"></flink-backpressure-badge>
</td>
</tr>
</tbody>
