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) + " "