Added additional logging for a query mapping. Fixes
@@ -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 {
