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 16d09a5afe..746726c905 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 @@ -61,9 +61,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 4c59d93bb1..0df36c0040 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 @@ -92,9 +92,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;