This is an automated email from the ASF dual-hosted git repository. sk0x50 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push: new e5f0fff IGNITE-13869 Added additional logging for a query mapping. Fixes #8585 e5f0fff is described below commit e5f0fffc9ff1d7ce97a74eda971f570335a2db3f Author: Alexander Lapin <lapin1...@gmail.com> AuthorDate: Wed Dec 23 00:15:45 2020 +0300 IGNITE-13869 Added additional logging for a query mapping. Fixes #8585 Signed-off-by: Slava Koptilin <slava.kopti...@gmail.com> --- .../internal/processors/query/h2/IgniteH2Indexing.java | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java index 6d4b4e3..4a7513c 100644 --- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java +++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/IgniteH2Indexing.java @@ -2223,10 +2223,18 @@ public class IgniteH2Indexing implements GridQueryIndexing { try { boolean processed = true; - if (msg instanceof GridQueryNextPageRequest) + boolean tracebleMsg = false; + + if (msg instanceof GridQueryNextPageRequest) { mapQueryExecutor().onNextPageRequest(node, (GridQueryNextPageRequest)msg); - else if (msg instanceof GridQueryNextPageResponse) + + tracebleMsg = true; + } + else if (msg instanceof GridQueryNextPageResponse) { reduceQueryExecutor().onNextPage(node, (GridQueryNextPageResponse)msg); + + tracebleMsg = true; + } else if (msg instanceof GridH2QueryRequest) mapQueryExecutor().onQueryRequest(node, (GridH2QueryRequest)msg); else if (msg instanceof GridH2DmlRequest) @@ -2240,11 +2248,11 @@ public class IgniteH2Indexing implements GridQueryIndexing { else processed = false; - if (processed && log.isDebugEnabled()) - log.debug("Processed message " + msg.getClass().getName() + ": " + nodeId + "->" + ctx.localNodeId() + " " + msg); + if (processed && log.isDebugEnabled() && (!tracebleMsg || log.isTraceEnabled())) + log.debug("Processed message: [srcNodeId=" + nodeId + ", msg=" + msg + ']'); } catch (Throwable th) { - U.error(log, "Failed to process message: " + msg, th); + U.error(log, "Failed to process message: [srcNodeId=" + nodeId + ", msg=" + msg + ']', th); } } finally {