You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/07/02 15:12:28 UTC
[doris] 01/03: [fix](proc) Fix show proc '/current_query_stmts' error due to wrong index for execTime (#10488)
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 <55...@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 <ca...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org