You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by li...@apache.org on 2019/08/01 05:53:27 UTC
[zeppelin] branch master updated: [ZEPPELIN-4240] Fixed the date
format error in cluster management page
This is an automated email from the ASF dual-hosted git repository.
liuxun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/master by this push:
new e391de0 [ZEPPELIN-4240] Fixed the date format error in cluster management page
e391de0 is described below
commit e391de0009acda1ae0e2c1b35c110702a16ab644
Author: Xun Liu <li...@apache.org>
AuthorDate: Tue Jul 16 13:47:08 2019 +0800
[ZEPPELIN-4240] Fixed the date format error in cluster management page
### What is this PR for?
The startup time of the zeppelin service and the interpreter process in the cluster metadata. The heartbeat time is the LocalDateTime.
The correct format is not displayed in the cluster management page.
### What type of PR is it?
[Bug Fix]
### What is the Jira issue?
* https://issues.apache.org/jira/browse/ZEPPELIN-4240
### How should this be tested?
* [CI Pass](https://travis-ci.org/liuxunorg/zeppelin/builds/558822999)
### Screenshots (if appropriate)
# Before fixed
# After fixed
### Questions:
* Does the licenses files need update?
* Is there breaking changes for older versions?
* Does this needs documentation?
Author: Xun Liu <li...@apache.org>
Closes #3407 from liuxunorg/ZEPPELIN-4240 and squashes the following commits:
bd07e6c1d [Xun Liu] modify function `formatLocalDateTime(...)`
f1fa1a61c [Xun Liu] [ZEPPELIN-4240] Formatted display service time in the cluster management page
---
.../org/apache/zeppelin/rest/ClusterRestApi.java | 52 ++++++++++++++++++++--
1 file changed, 48 insertions(+), 4 deletions(-)
diff --git a/zeppelin-server/src/main/java/org/apache/zeppelin/rest/ClusterRestApi.java b/zeppelin-server/src/main/java/org/apache/zeppelin/rest/ClusterRestApi.java
index ef81a13..bcdb2be 100644
--- a/zeppelin-server/src/main/java/org/apache/zeppelin/rest/ClusterRestApi.java
+++ b/zeppelin-server/src/main/java/org/apache/zeppelin/rest/ClusterRestApi.java
@@ -32,6 +32,8 @@ import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.Response;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
@@ -130,13 +132,29 @@ public class ClusterRestApi {
}
if (properties.containsKey(ClusterMeta.SERVER_START_TIME)) {
- sortProperties.put(ClusterMeta.SERVER_START_TIME, properties.get(ClusterMeta.SERVER_START_TIME));
+ // format LocalDateTime
+ Object serverStartTime = properties.get(ClusterMeta.SERVER_START_TIME);
+ if (serverStartTime instanceof LocalDateTime) {
+ LocalDateTime localDateTime = (LocalDateTime) serverStartTime;
+ String dateTime = formatLocalDateTime(localDateTime);
+ sortProperties.put(ClusterMeta.SERVER_START_TIME, dateTime);
+ } else {
+ sortProperties.put(ClusterMeta.SERVER_START_TIME, "Wrong time type!");
+ }
}
if (properties.containsKey(ClusterMeta.STATUS)) {
sortProperties.put(ClusterMeta.STATUS, properties.get(ClusterMeta.STATUS));
}
if (properties.containsKey(ClusterMeta.LATEST_HEARTBEAT)) {
- sortProperties.put(ClusterMeta.LATEST_HEARTBEAT, properties.get(ClusterMeta.LATEST_HEARTBEAT));
+ // format LocalDateTime
+ Object latestHeartbeat = properties.get(ClusterMeta.LATEST_HEARTBEAT);
+ if (latestHeartbeat instanceof LocalDateTime) {
+ LocalDateTime localDateTime = (LocalDateTime) latestHeartbeat;
+ String dateTime = formatLocalDateTime(localDateTime);
+ sortProperties.put(ClusterMeta.LATEST_HEARTBEAT, dateTime);
+ } else {
+ sortProperties.put(ClusterMeta.LATEST_HEARTBEAT, "Wrong time type!");
+ }
}
if (properties.containsKey(ClusterMeta.INTP_PROCESS_LIST)) {
sortProperties.put(ClusterMeta.INTP_PROCESS_LIST, properties.get(ClusterMeta.INTP_PROCESS_LIST));
@@ -152,8 +170,10 @@ public class ClusterRestApi {
return new JsonResponse(Response.Status.OK, "", nodes).build();
}
- private String formatIntpLink(String intpName) {
- return String.format("<a href=\"/#/cluster/%s\">%s</a>", intpName, intpName);
+ private String formatLocalDateTime(LocalDateTime localDateTime) {
+ DateTimeFormatter dtf = DateTimeFormatter.ISO_DATE_TIME;
+ String strDate = localDateTime.format(dtf);
+ return strDate;
}
/**
@@ -177,6 +197,30 @@ public class ClusterRestApi {
HashMap<String, Object> node = new HashMap<String, Object>();
node.put(ClusterMeta.NODE_NAME, intpNodeName);
node.put(PROPERTIES, intpMetaEntity.getValue());
+
+ // format LocalDateTime
+ HashMap<String, Object> properties = intpMetaEntity.getValue();
+ if (properties.containsKey(ClusterMeta.INTP_START_TIME)) {
+ Object intpStartTime = properties.get(ClusterMeta.INTP_START_TIME);
+ if (intpStartTime instanceof LocalDateTime) {
+ LocalDateTime localDateTime = (LocalDateTime) intpStartTime;
+ String dateTime = formatLocalDateTime(localDateTime);
+ properties.put(ClusterMeta.INTP_START_TIME, dateTime);
+ } else {
+ properties.put(ClusterMeta.INTP_START_TIME, "Wrong time type!");
+ }
+ }
+ if (properties.containsKey(ClusterMeta.LATEST_HEARTBEAT)) {
+ Object latestHeartbeat = properties.get(ClusterMeta.LATEST_HEARTBEAT);
+ if (latestHeartbeat instanceof LocalDateTime) {
+ LocalDateTime localDateTime = (LocalDateTime) latestHeartbeat;
+ String dateTime = formatLocalDateTime(localDateTime);
+ properties.put(ClusterMeta.LATEST_HEARTBEAT, dateTime);
+ } else {
+ properties.put(ClusterMeta.LATEST_HEARTBEAT, "Wrong time type!");
+ }
+ }
+
intpProcesses.add(node);
}
}