This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 7a89994 [FLINK-22489][webui] Fix displaying individual subtasks
backpressure-level
7a89994 is described below
commit 7a899941f486f0668c7959cd03bc4337a872d81b
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 e39f951..43ad8b3 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'] + 1 }}</td>
<td>{{ subtask['ratio'] }}</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>
