[incubator-seatunnel] branch dev updated: [Improve][Zeta][metrics] add jobId in job progress Information

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 42bb01293 [Improve][Zeta][metrics] add jobId in job progress 
Information
42bb01293 is described below

commit 42bb0129327fef63e5e048baa7985b3d1b96ff30
Author: Guangdong Liu <804167...@qq.com>
AuthorDate: Tue Feb 7 20:36:47 2023 +0800

    [Improve][Zeta][metrics] add jobId in job progress Information
---
 .../engine/client/job/JobMetricsRunner.java        | 28 ++++++++++++----------
 1 file changed, 15 insertions(+), 13 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobMetricsRunner.java
 
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobMetricsRunner.java
index fde095334..53eee675a 100644
--- 
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobMetricsRunner.java
+++ 
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobMetricsRunner.java
@@ -51,24 +51,26 @@ public class JobMetricsRunner implements Runnable {
             long averageRead = (jobMetricsSummary.getSourceReadCount() - 
lastReadCount) / seconds;
             long averageWrite = (jobMetricsSummary.getSinkWriteCount() - 
lastWriteCount) / seconds;
             log.info(StringFormatUtils.formatTable(
-                    "Job Progress Information",
-                    "Read Count So Far",
-                    jobMetricsSummary.getSourceReadCount(),
+                "Job Progress Information",
+                "Job Id",
+                jobId,
+                "Read Count So Far",
+                jobMetricsSummary.getSourceReadCount(),
 
-                    "Write Count So Far",
-                    jobMetricsSummary.getSinkWriteCount(),
+                "Write Count So Far",
+                jobMetricsSummary.getSinkWriteCount(),
 
-                    "Average Read Count",
-                    averageRead + "/s",
+                "Average Read Count",
+                averageRead + "/s",
 
-                    "Average Write Count",
-                    averageWrite + "/s",
+                "Average Write Count",
+                averageWrite + "/s",
 
-                    "Last Statistic Time",
-                    DateTimeUtils.toString(lastRunTime, 
DateTimeUtils.Formatter.YYYY_MM_DD_HH_MM_SS),
+                "Last Statistic Time",
+                DateTimeUtils.toString(lastRunTime, 
DateTimeUtils.Formatter.YYYY_MM_DD_HH_MM_SS),
 
-                    "Current Statistic Time",
-                    DateTimeUtils.toString(now, 
DateTimeUtils.Formatter.YYYY_MM_DD_HH_MM_SS)));
+                "Current Statistic Time",
+                DateTimeUtils.toString(now, 
DateTimeUtils.Formatter.YYYY_MM_DD_HH_MM_SS)));
             lastRunTime = now;
             lastReadCount = jobMetricsSummary.getSourceReadCount();
             lastWriteCount = jobMetricsSummary.getSinkWriteCount();