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;
+  }
 }

Reply via email to