[doris] 01/03: [fix](proc) Fix show proc '/current_query_stmts' error due to wrong index for execTime (#10488)

[morningman]

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

morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 378a5a3a4e14b3280d37c2092a8fb7c83709c3d3
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 3b0474d9b0..e9ccb9c3e3 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
@@ -35,7 +35,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 493ce936cc..b54f6f8aa9 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
@@ -94,9 +94,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