xtern commented on code in PR #2925:
URL: https://github.com/apache/ignite-3/pull/2925#discussion_r1418790008
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImpl.java:
##########
@@ -454,6 +475,120 @@ private DistributedQueryManager
getOrCreateQueryManager(String coordinatorNodeNa
});
}
+ /**
+ * Collects debug information about current state of execution.
+ *
+ *<p>This information has the following format:
+ *
+ *<pre>
+ *Debug info for query: [uuid] (canceled=[true/false],
stopped=[true/false])
+ * Coordinator node: [nodeName] [(current node)]
+ * Root node state: [opened/closed/absent/exception]
+ *
+ * Fragments awaiting init completion:
+ * id=[id], node=[nodeName]"
+ * ...
+ *
+ * Local fragments:
+ * id=[id], state=[opened/closed], canceled=[true/false],
class=[SimpleClassName] [(root)]
+ * ...
+ *
+ *...
+ *</pre>
+ *
+ * @return String containing debugging information.
+ */
+ String dumpDebugInfo() {
+ IgniteStringBuilder buf = new IgniteStringBuilder();
+
+ for (Map.Entry<UUID, DistributedQueryManager> entry :
queryManagerMap.entrySet()) {
+ UUID queryId = entry.getKey();
+ DistributedQueryManager mgr = entry.getValue();
+
+ Long rootFragmentId = mgr.rootFragmentId;
+
+ if (rootFragmentId == null) {
Review Comment:
Fixed, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
