[ignite-3] branch main updated: IGNITE-14836: fix SQL messages groupType

[tl...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tledkov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new a917f9d  IGNITE-14836: fix SQL messages groupType
a917f9d is described below

commit a917f9d75da60a65c805f32e552cf1fe227bd1e7
Author: tledkov <tl...@gridgain.com>
AuthorDate: Thu Jul 22 15:36:00 2021 +0300

    IGNITE-14836: fix SQL messages groupType
---
 .../internal/processors/query/calcite/message/MessageServiceImpl.java   | 2 +-
 .../internal/processors/query/calcite/message/SqlQueryMessageGroup.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java
index 96e9ba1..fc13c49 100644
--- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java
+++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java
@@ -141,7 +141,7 @@ public class MessageServiceImpl implements MessageService {
     private void onMessageInternal(String nodeId, NetworkMessage msg) {
         MessageListener lsnr = Objects.requireNonNull(
                 lsnrs.get(msg.messageType()),
-                "there is no listener for msgType=" + msg.groupType()
+                "there is no listener for msgType=" + msg.messageType()
         );
 
         lsnr.onMessage(nodeId, msg);
diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/SqlQueryMessageGroup.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/SqlQueryMessageGroup.java
index e8cbc84..a8db29e 100644
--- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/SqlQueryMessageGroup.java
+++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/SqlQueryMessageGroup.java
@@ -22,7 +22,7 @@ import org.apache.ignite.network.annotations.MessageGroup;
 /**
  * Message types for the sql query processing module.
  */
-@MessageGroup(groupType = 3, groupName = "SqlQueryMessages")
+@MessageGroup(groupType = 4, groupName = "SqlQueryMessages")
 public final class SqlQueryMessageGroup {
     public static final short QUERY_START_REQUEST = 0;