Skip to content

[FLINK-39376] [checkpoint]Add IP Address of Subtask Running Checkpoint to Flink WebU #27876

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wangxiaojing wants to merge 3 commits into
base: master
Choose a base branch
from
Open

[FLINK-39376] [checkpoint]Add IP Address of Subtask Running Checkpoint to Flink WebU #27876

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
2a17d17
Add IP Address of Subtask Running Checkpoint to Flink WebU
Apr 1, 2026
f498514
[webui] Show subtask endpoint in checkpoint statistics via existing v…
Apr 20, 2026
94f8c9e
Merge remote-tracking branch 'origin/master' into wxj-show-TaskManage…
Apr 20, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions ...eb-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -144,6 +144,7 @@
<thead>
<tr>
<th><strong>ID</strong></th>
<th [nzSortFn]="sortEndpointFn"><strong>Endpoint</strong></th>
<th [nzSortFn]="sortAckTimestampFn"><strong>Acknowledged</strong></th>
<th [nzSortFn]="sortEndToEndDurationFn"><strong>End to End Duration</strong></th>
<th [nzSortFn]="sortCheckpointedSizeFn">
Expand All @@ -166,6 +167,7 @@
<tbody>
<tr *ngFor="let subTask of table.data">
<td>{{ subTask['index'] }}</td>
<td>{{ mapOfSubtask.get(subTask['index'])?.endpoint || '-' }}</td>
<ng-container *ngIf="subTask['status'] === 'completed'">
<td>{{ subTask['ack_timestamp'] | date: 'yyyy-MM-dd HH:mm:ss.SSS' }}</td>
<td>
Expand Down
17 changes: 11 additions & 6 deletions .../web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,13 +48,13 @@ import { NzTableModule, NzTableSortFn } from 'ng-zorro-antd/table';
import { JobLocalService } from '../../job-local.service';

function createSortFn(
selector: (item: CompletedSubTaskCheckpointStatistics) => number | boolean
selector: (item: CompletedSubTaskCheckpointStatistics) => number | boolean | string | null
): NzTableSortFn<SubTaskCheckpointStatisticsItem> {
// FIXME This type-asserts that pre / next are a specific subtype.
return (pre, next) =>
selector(pre as CompletedSubTaskCheckpointStatistics) > selector(next as CompletedSubTaskCheckpointStatistics)
? 1
: -1;
return (pre, next) => {
const a = selector(pre as CompletedSubTaskCheckpointStatistics) ?? '';
const b = selector(next as CompletedSubTaskCheckpointStatistics) ?? '';
return a > b ? 1 : -1;
};
Copy link
Copy Markdown
Contributor

@zhuzhurk zhuzhurk Apr 21, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Changes to createSortFn are not needed, since sortEndpointFn is implemented separately without using it.

}

@Component({
Expand All @@ -77,6 +77,11 @@ export class JobCheckpointsSubtaskComponent implements OnInit, OnChanges, OnDest
public mapOfSubtask: Map<number, JobVertexSubTaskData> = new Map();

public readonly sortAckTimestampFn = createSortFn(item => item.ack_timestamp);
public readonly sortEndpointFn: NzTableSortFn<SubTaskCheckpointStatisticsItem> = (a, b) => {
const endpointA = this.mapOfSubtask.get(a['index'])?.endpoint ?? '';
const endpointB = this.mapOfSubtask.get(b['index'])?.endpoint ?? '';
return endpointA > endpointB ? 1 : endpointA < endpointB ? -1 : 0;
};
public readonly sortEndToEndDurationFn = createSortFn(item => item.end_to_end_duration);
public readonly sortCheckpointedSizeFn = createSortFn(item => item.checkpointed_size);
public readonly sortStateSizeFn = createSortFn(item => item.state_size);
Expand Down