This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push: new c695ccb827 [fix](proc) Fix show proc '/current_query_stmts' error due to wrong index for execTime (#10488) c695ccb827 is described below commit c695ccb827d7d072413b24cb72e3bc5e50bcbec8 Author: caiconghui <55968745+caicong...@users.noreply.github.com> AuthorDate: Wed Jun 29 17:41:47 2022 +0800 [fix](proc) Fix show proc '/current_query_stmts' error due to wrong index for execTime (#10488) Co-authored-by: caiconghui1 <caicongh...@jd.com> --- .../org/apache/doris/common/proc/CurrentQueryStatementsProcNode.java | 2 +- .../src/main/java/org/apache/doris/common/proc/TrashProcDir.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatementsProcNode.java b/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatementsProcNode.java index d757de2067..1a710e2e91 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatementsProcNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatementsProcNode.java @@ -36,7 +36,7 @@ public class CurrentQueryStatementsProcNode implements ProcNodeInterface { .add("QueryId").add("ConnectionId").add("Database").add("User") .add("ExecTime").add("SqlHash").add("Statement").build(); - private static final int EXEC_TIME_INDEX = 5; + private static final int EXEC_TIME_INDEX = 4; @Override public ProcResult fetchResult() throws AnalysisException { diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/proc/TrashProcDir.java b/fe/fe-core/src/main/java/org/apache/doris/common/proc/TrashProcDir.java index 148150281d..25963a0c96 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/proc/TrashProcDir.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/proc/TrashProcDir.java @@ -92,9 +92,9 @@ public class TrashProcDir implements ProcDirInterface { } } - List<String> backendInfo = new ArrayList<String>(); + List<String> backendInfo = new ArrayList<>(); backendInfo.add(String.valueOf(backend.getId())); - backendInfo.add(backend.getHost() + ":" + String.valueOf(backend.getHeartbeatPort())); + backendInfo.add(backend.getHost() + ":" + backend.getHeartbeatPort()); if (trashUsedCapacityB != null) { Pair<Double, String> trashUsedCapacity = DebugUtil.getByteUint(trashUsedCapacityB); backendInfo.add(DebugUtil.DECIMAL_FORMAT_SCALE_3.format(trashUsedCapacity.first) + " " --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org