From c695ccb827d7d072413b24cb72e3bc5e50bcbec8 Mon Sep 17 00:00:00 2001 From: caiconghui <55968745+caiconghui@users.noreply.github.com> Date: Wed, 29 Jun 2022 17:41:47 +0800 Subject: [PATCH] [fix](proc) Fix show proc '/current_query_stmts' error due to wrong index for execTime (#10488) Co-authored-by: caiconghui1 --- .../doris/common/proc/CurrentQueryStatementsProcNode.java | 2 +- .../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 backendInfo = new ArrayList(); + List 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 trashUsedCapacity = DebugUtil.getByteUint(trashUsedCapacityB); backendInfo.add(DebugUtil.DECIMAL_FORMAT_SCALE_3.format(trashUsedCapacity.first) + " "