This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new fc95b4b797b [bug](proc) fix NumberFormatException in show proc
'/current_queries'(https://github.com/apache/doris/pull/21400) (#29549)
fc95b4b797b is described below
commit fc95b4b797b9a198effe9c62be291f13d95a5d2f
Author: momoba <[email protected]>
AuthorDate: Sat Jan 6 13:45:51 2024 +0800
[bug](proc) fix NumberFormatException in show proc
'/current_queries'(https://github.com/apache/doris/pull/21400) (#29549)
---
.../apache/doris/common/proc/CurrentQueryStatementsProcNode.java | 6 +++---
.../org/apache/doris/common/proc/CurrentQueryStatisticsProcDir.java | 6 +++---
2 files changed, 6 insertions(+), 6 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 1a710e2e917..03ab5e77bf1 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
@@ -60,9 +60,9 @@ public class CurrentQueryStatementsProcNode implements
ProcNodeInterface {
// sort according to ExecTime
sortedRowData.sort((l1, l2) -> {
- final int execTime1 = Integer.parseInt(l1.get(EXEC_TIME_INDEX));
- final int execTime2 = Integer.parseInt(l2.get(EXEC_TIME_INDEX));
- return execTime2 - execTime1;
+ final long execTime1 = Long.parseLong(l1.get(EXEC_TIME_INDEX));
+ final long execTime2 = Long.parseLong(l2.get(EXEC_TIME_INDEX));
+ return Long.compare(execTime2, execTime1);
});
result.setRows(sortedRowData);
return result;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatisticsProcDir.java
b/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatisticsProcDir.java
index acb1cbf5edd..d3c6db9d988 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatisticsProcDir.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/common/proc/CurrentQueryStatisticsProcDir.java
@@ -91,9 +91,9 @@ public class CurrentQueryStatisticsProcDir implements
ProcDirInterface {
}
// sort according to ExecTime
sortedRowData.sort((l1, l2) -> {
- final int execTime1 = Integer.parseInt(l1.get(EXEC_TIME_INDEX));
- final int execTime2 = Integer.parseInt(l2.get(EXEC_TIME_INDEX));
- return execTime2 - execTime1;
+ final long execTime1 = Long.parseLong(l1.get(EXEC_TIME_INDEX));
+ final long execTime2 = Long.parseLong(l2.get(EXEC_TIME_INDEX));
+ return Long.compare(execTime2, execTime1);
});
result.setRows(sortedRowData);
return result;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
