IGNITE-5376: JDBC thin: added "collocated" and "replicatedOnly" flags (2).
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/986c07a0 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/986c07a0 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/986c07a0 Branch: refs/heads/ignite-5293 Commit: 986c07a0788b5c73c0f1afcd4fb8eee2f1a84a12 Parents: a973392 Author: devozerov <[email protected]> Authored: Mon Jun 5 23:16:36 2017 +0300 Committer: devozerov <[email protected]> Committed: Mon Jun 5 23:16:36 2017 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 4 ++-- .../ignite/internal/processors/odbc/SqlListenerNioListener.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/986c07a0/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinTcpIo.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinTcpIo.java b/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinTcpIo.java index bf8234d..1905ea4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinTcpIo.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/JdbcThinTcpIo.java @@ -53,10 +53,10 @@ public class JdbcThinTcpIo { private static final SqlListenerProtocolVersion CURRENT_VER = SqlListenerProtocolVersion.create(2, 1, 0); /** Initial output stream capacity for handshake. */ - private static final int HANDSHAKE_MSG_SIZE = 10; + private static final int HANDSHAKE_MSG_SIZE = 12; /** Initial output for query message. */ - private static final int QUERY_EXEC_MSG_INIT_CAP = 1024; + private static final int QUERY_EXEC_MSG_INIT_CAP = 256; /** Initial output for query fetch message. */ private static final int QUERY_FETCH_MSG_SIZE = 13; http://git-wip-us.apache.org/repos/asf/ignite/blob/986c07a0/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/SqlListenerNioListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/SqlListenerNioListener.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/SqlListenerNioListener.java index e00b001..fb3359a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/SqlListenerNioListener.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/SqlListenerNioListener.java @@ -256,7 +256,7 @@ public class SqlListenerNioListener extends GridNioServerListenerAdapter<byte[]> SqlListenerRequestHandler handler = new JdbcRequestHandler(ctx, busyLock, maxCursors, distributedJoins, enforceJoinOrder, collocated, replicatedOnly); - SqlListenerMessageParser parser = new OdbcMessageParser(ctx); + SqlListenerMessageParser parser = new JdbcMessageParser(ctx); return new SqlListenerConnectionContext(handler, parser); }
