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

alexpl 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 1336f1b  IGNITE-13164 Thin client: Fix nodeIds format for execute 
compute tasks request - Fixes #7944.
1336f1b is described below

commit 1336f1bc454493e102f6c2acecaa03e511d8eb45
Author: Aleksey Plekhanov <[email protected]>
AuthorDate: Tue Jun 23 08:13:02 2020 +0500

    IGNITE-13164 Thin client: Fix nodeIds format for execute compute tasks 
request - Fixes #7944.
    
    Signed-off-by: Aleksey Plekhanov <[email protected]>
---
 .../apache/ignite/internal/client/thin/ClientComputeImpl.java | 11 ++++++-----
 .../platform/client/compute/ClientExecuteTaskRequest.java     |  2 +-
 .../Apache.Ignite.Core/Impl/Client/Compute/ComputeClient.cs   |  2 +-
 3 files changed, 8 insertions(+), 7 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientComputeImpl.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientComputeImpl.java
index 3d53c010..81cb0f3 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientComputeImpl.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/client/thin/ClientComputeImpl.java
@@ -34,7 +34,6 @@ import org.apache.ignite.client.ClientException;
 import org.apache.ignite.client.ClientFeatureNotSupportedByServerException;
 import org.apache.ignite.internal.IgniteInternalFuture;
 import org.apache.ignite.internal.binary.BinaryRawWriterEx;
-import org.apache.ignite.internal.binary.BinaryWriterExImpl;
 import org.apache.ignite.internal.binary.streams.BinaryHeapInputStream;
 import org.apache.ignite.internal.processors.platform.client.ClientStatus;
 import org.apache.ignite.internal.util.future.GridFutureAdapter;
@@ -235,20 +234,22 @@ class ClientComputeImpl implements ClientCompute, 
NotificationListener {
                 "client not supported by server node (" + 
ch.clientChannel().serverNodeId() + ')');
         }
 
-        try (BinaryRawWriterEx w = new BinaryWriterExImpl(marsh.context(), 
ch.out(), null, null)) {
+        try (BinaryRawWriterEx w = utils.createBinaryWriter(ch.out())) {
             if (nodeIds == null) // Include all nodes.
                 w.writeInt(0);
             else {
                 w.writeInt(nodeIds.size());
 
-                for (UUID nodeId : nodeIds)
-                    w.writeUuid(nodeId);
+                for (UUID nodeId : nodeIds) {
+                    w.writeLong(nodeId.getMostSignificantBits());
+                    w.writeLong(nodeId.getLeastSignificantBits());
+                }
             }
 
             w.writeByte(flags);
             w.writeLong(timeout);
             w.writeString(taskName);
-            utils.writeObject(ch.out(), arg);
+            w.writeObject(arg);
         }
     }
 
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/compute/ClientExecuteTaskRequest.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/compute/ClientExecuteTaskRequest.java
index ce41e37..9f4fc62 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/compute/ClientExecuteTaskRequest.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/compute/ClientExecuteTaskRequest.java
@@ -59,7 +59,7 @@ public class ClientExecuteTaskRequest extends ClientRequest {
         nodeIds = U.newHashSet(cnt);
 
         for (int i = 0; i < cnt; i++)
-            nodeIds.add(reader.readUuid());
+            nodeIds.add(new UUID(reader.readLong(), reader.readLong()));
 
         flags = reader.readByte();
 
diff --git 
a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Compute/ComputeClient.cs
 
b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Compute/ComputeClient.cs
index 4ef2a134..a02608f 100644
--- 
a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Compute/ComputeClient.cs
+++ 
b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Compute/ComputeClient.cs
@@ -147,7 +147,7 @@ namespace Apache.Ignite.Core.Impl.Client.Compute
 
                 foreach (var node in nodes)
                 {
-                    writer.WriteGuid(node.Id);
+                    BinaryUtils.WriteGuid(node.Id, ctx.Stream);
                 }
             }
             else

Reply via email to