This is an automated email from the ASF dual-hosted git repository.
tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9e6bcee710b [FLINK-36127][web] support sort watermark
9e6bcee710b is described below
commit 9e6bcee710b13b8f64a73c99c3164f7551e1e829
Author: candaccc <[email protected]>
AuthorDate: Wed Aug 21 22:11:49 2024 +1000
[FLINK-36127][web] support sort watermark
---
.../watermarks/job-overview-drawer-watermarks.component.html | 6 +++---
.../overview/watermarks/job-overview-drawer-watermarks.component.ts | 4 ++++
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git
a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.html
b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.html
index f82a4b40921..4241e5387dd 100644
---
a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.html
+++
b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.html
@@ -31,9 +31,9 @@
>
<thead>
<tr>
- <th nzWidth="33%">SubTask</th>
- <th nzWidth="33%">Watermark</th>
- <th nzWidth="34%">
+ <th nzWidth="20%">SubTask</th>
+ <th nzWidth="40%" [nzSortFn]="sortWatermark">Watermark</th>
+ <th nzWidth="40%" [nzSortFn]="sortWatermark">
Datetime of Watermark Timestamp
<i
class="header-icon"
diff --git
a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.ts
b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.ts
index 580aaf15d27..de90df47868 100644
---
a/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.ts
+++
b/flink-runtime-web/web-dashboard/src/app/pages/job/overview/watermarks/job-overview-drawer-watermarks.component.ts
@@ -97,4 +97,8 @@ export class JobOverviewDrawerWatermarksComponent implements
OnInit, OnDestroy {
this.destroy$.next();
this.destroy$.complete();
}
+
+ sortWatermark(a: WatermarkData, b: WatermarkData): number {
+ return a.watermark - b.watermark;
+ }
}