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 <[email protected]>
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 <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
