IGNITE-27226 Use MessageSerializer for QueryStartRequest (#12548)

Author: Vladsz83

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java

@@ -882,7 +882,7 @@ private void onMessage(UUID nodeId, final QueryStartRequest msg) {
             );
 
             final BaseQueryContext qctx = createQueryContext(
-                msg.appAttrs() == null ? Contexts.empty() : Contexts.of(new SessionContextImpl(msg.appAttrs())),
+                msg.applicationAttributes() == null ? Contexts.empty() : Contexts.of(new SessionContextImpl(msg.applicationAttributes())),
                 msg.schema());
 
             QueryPlan qryPlan = queryPlanCache().queryPlan(
@@ -903,7 +903,7 @@ private void onMessage(UUID nodeId, final QueryStartRequest msg) {
                 msg.fragmentDescription(),
                 handler,
                 qry.createMemoryTracker(memoryTracker, cfg.getQueryMemoryQuota()),
-                createIoTracker(nodeId, msg.originatingQryId()),
+                createIoTracker(nodeId, msg.originatingQueryId()),
                 msg.timeout(),
                 Commons.parametersMap(msg.parameters()),
                 msg.queryTransactionEntries()

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageType.java

@@ -27,6 +27,7 @@
 import org.apache.ignite.internal.codegen.QueryBatchAcknowledgeMessageSerializer;
 import org.apache.ignite.internal.codegen.QueryBatchMessageSerializer;
 import org.apache.ignite.internal.codegen.QueryCloseMessageSerializer;
+import org.apache.ignite.internal.codegen.QueryStartRequestSerializer;
 import org.apache.ignite.internal.codegen.QueryStartResponseSerializer;
 import org.apache.ignite.internal.codegen.QueryTxEntrySerializer;
 import org.apache.ignite.internal.processors.query.calcite.metadata.ColocationGroup;
@@ -39,7 +40,7 @@
  */
 public enum MessageType {
     /** */
-    QUERY_START_REQUEST(300, QueryStartRequest::new),
+    QUERY_START_REQUEST(300, QueryStartRequest::new, new QueryStartRequestSerializer()),
 
     /** */
     QUERY_START_RESPONSE(301, QueryStartResponse::new, new QueryStartResponseSerializer()),