You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sk...@apache.org on 2020/12/22 21:17:01 UTC
[ignite] branch master updated: IGNITE-13869 Added additional
logging for a query mapping. Fixes #8585
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 <la...@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 <sl...@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 {