Skip to content

Commit bb2c7a1

Browse files
committed
[FLINK-39394][web] Fix job overview metrics broken when a vertex is finished
1 parent c24f964 commit bb2c7a1

1 file changed

Lines changed: 11 additions & 5 deletions

File tree

flink-runtime-web/web-dashboard/src/app/pages/job/overview/job-overview.component.ts

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -169,11 +169,16 @@ export class JobOverviewComponent implements OnInit, OnDestroy {
169169
map(result => {
170170
return {
171171
...node,
172-
backPressuredPercentage: Math.min(Math.round(result.backPressuredTimeMsPerSecond.max / 10), 100),
173-
busyPercentage: Math.min(Math.round(result.busyTimeMsPerSecond.max / 10), 100),
174-
dataSkewPercentage: result.numRecordsInPerSecond.skew
172+
backPressuredPercentage: result.backPressuredTimeMsPerSecond
173+
? Math.min(Math.round(result.backPressuredTimeMsPerSecond.max / 10), 100)
174+
: NaN,
175+
busyPercentage: result.busyTimeMsPerSecond
176+
? Math.min(Math.round(result.busyTimeMsPerSecond.max / 10), 100)
177+
: NaN,
178+
dataSkewPercentage: result.numRecordsInPerSecond?.skew ?? NaN
175179
};
176-
})
180+
}),
181+
catchError(() => of(node))
177182
);
178183
})
179184
).pipe(catchError(() => of(nodes)));
@@ -185,7 +190,8 @@ export class JobOverviewComponent implements OnInit, OnDestroy {
185190
return this.metricService.loadWatermarks(this.jobId, node.id).pipe(
186191
map(result => {
187192
return { ...node, lowWatermark: result.lowWatermark };
188-
})
193+
}),
194+
catchError(() => of(node))
189195
);
190196
})
191197
).pipe(catchError(() => of(nodes)));

0 commit comments

Comments
 (0)