ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject ignite git commit: IGNITE-5376: JDBC thin: added "collocated" and "replicatedOnly" flags (2).
Date Mon, 05 Jun 2017 20:17:02 GMT
Repository: ignite
Updated Branches:
  refs/heads/master a9733921f -> 986c07a07


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/master
Commit: 986c07a0788b5c73c0f1afcd4fb8eee2f1a84a12
Parents: a973392
Author: devozerov <ppozerov@gmail.com>
Authored: Mon Jun 5 23:16:36 2017 +0300
Committer: devozerov <ppozerov@gmail.com>
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);
         }


Mime
View raw message