You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by pt...@apache.org on 2022/05/30 19:35:39 UTC
[ignite-3] 03/03: wip propagate arguments
This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a commit to branch ignite-14972
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit f81b53820cebe2f9a29bfe70be7db18d7063a2e0
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Mon May 30 22:35:29 2022 +0300
wip propagate arguments
---
.../ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java | 2 +-
.../apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java
index bc52a2937..224306b1c 100644
--- a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java
+++ b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java
@@ -162,7 +162,7 @@ public class ClientSqlExecuteRequest {
}
private static Object[] readArguments(ClientMessageUnpacker in) {
- int size = in.unpackInt();
+ int size = in.unpackArrayHeader();
if (size == 0) {
return ArrayUtils.OBJECT_EMPTY_ARRAY;
diff --git a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
index 170ce83e2..bfd7b6f6f 100644
--- a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
+++ b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
@@ -71,7 +71,7 @@ public class ItThinClientSqlTest extends ItAbstractThinClientTest {
AsyncResultSet insertRes = session.executeAsync(null, "INSERT INTO TEST VALUES (?, ?)", 1, "hello").join();
assertFalse(insertRes.hasRowSet());
- assertTrue(insertRes.wasApplied());
+ assertFalse(insertRes.wasApplied());
assertEquals(1, insertRes.affectedRows());
assertThrows(NoRowSetExpectedException.class, createRes::currentPage);
}