Log finalQueryInfo when FTE scheduler stalled

trinodb · Dec 15, 2023 · 982be2a · 982be2a
1 parent 2407eb9
commit 982be2a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...va/io/trino/execution/scheduler/faulttolerant/EventDrivenFaultTolerantQueryScheduler.java b/...va/io/trino/execution/scheduler/faulttolerant/EventDrivenFaultTolerantQueryScheduler.java
@@ -936,6 +936,7 @@ private void logDebugInfo(String reason)
             log.debug("Scheduler debug info for %s START; reason=%s", queryStateMachine.getQueryId(), reason);
             log.debug("General state: %s", toStringHelper(this)
                     .add("queryState", queryStateMachine.getQueryState())
+                    .add("finalQueryInfo", queryStateMachine.getFinalQueryInfo())
                     .add("maxTaskExecutionAttempts", maxTaskExecutionAttempts)
                     .add("maxTasksWaitingForNode", maxTasksWaitingForNode)
                     .add("maxTasksWaitingForExecution", maxTasksWaitingForExecution)