[opt](log) add more info in nereids timeout log

apache · Dec 20, 2024 · 8bce271 · 8bce271
1 parent 2a1209d
commit 8bce271
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/scheduler/SimpleJobScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/scheduler/SimpleJobScheduler.java
@@ -34,11 +34,11 @@ public void executeJobPool(ScheduleContext scheduleContext) {
         CascadesContext context = (CascadesContext) scheduleContext;
         SessionVariable sessionVariable = context.getConnectContext().getSessionVariable();
         while (!pool.isEmpty()) {
+            long elapsedS = context.getStatementContext().getStopwatch().elapsed(TimeUnit.MILLISECONDS) / 1000;
             if (sessionVariable.enableNereidsTimeout
-                    && context.getStatementContext().getStopwatch().elapsed(TimeUnit.MILLISECONDS)
-                    > sessionVariable.nereidsTimeoutSecond * 1000L) {
-                throw new AnalysisException(
-                        "Nereids cost too much time ( > " + sessionVariable.nereidsTimeoutSecond + "s )");
+                    && elapsedS > sessionVariable.nereidsTimeoutSecond) {
+                throw new AnalysisException(String.format("Nereids cost too much time ( %ds > %ds",
+                        elapsedS, sessionVariable.nereidsTimeoutSecond));
             }
             Job job = pool.pop();
             job.execute();