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 <[email protected]> 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); }
