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 15:44:19 UTC
[ignite-3] branch ignite-14972 updated: wip ClientSqlTest
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
The following commit(s) were added to refs/heads/ignite-14972 by this push:
new 6114df188 wip ClientSqlTest
6114df188 is described below
commit 6114df188bbdac6f674141449f8903287b433da5
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Mon May 30 18:44:13 2022 +0300
wip ClientSqlTest
---
.../org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java | 2 +-
.../main/java/org/apache/ignite/internal/client/TcpIgniteClient.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/ClientSqlCommon.java b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
index a952fe848..a480d92b3 100644
--- a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
+++ b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
@@ -40,7 +40,7 @@ class ClientSqlCommon {
}
if (!asyncResultSet.hasMorePages()) {
- asyncResultSet.close();
+ asyncResultSet.closeAsync();
}
}
}
diff --git a/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java b/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
index ef7449890..e75465107 100644
--- a/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
+++ b/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
@@ -131,7 +131,7 @@ public class TcpIgniteClient implements IgniteClient {
/** {@inheritDoc} */
@Override
public IgniteSql sql() {
- throw new UnsupportedOperationException("Not implemented yet.");
+ return new ClientSql(ch);
}
/** {@inheritDoc} */