Update RPC version number to correspond to changes in nullable buffer from bitmap to bytes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/496b5d0a Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/496b5d0a Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/496b5d0a Branch: refs/heads/master Commit: 496b5d0a1a8ce5e1cdaf06d127400f1e7e7687b0 Parents: d944918 Author: Jacques Nadeau <[email protected]> Authored: Wed Aug 27 17:31:59 2014 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Wed Aug 27 17:32:39 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/drill/exec/rpc/data/DataRpcConfig.java | 8 ++++---- .../java/org/apache/drill/exec/rpc/user/UserRpcConfig.java | 6 +++--- 2 files changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/496b5d0a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/data/DataRpcConfig.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/data/DataRpcConfig.java b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/data/DataRpcConfig.java index 6224827..45d95d9 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/data/DataRpcConfig.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/data/DataRpcConfig.java @@ -30,13 +30,13 @@ import org.apache.drill.exec.rpc.RpcConfig; public class DataRpcConfig { static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(DataRpcConfig.class); - + public static RpcConfig MAPPING = RpcConfig.newBuilder("BIT-DATA-RPC-MAPPING") // .add(RpcType.HANDSHAKE, BitClientHandshake.class, RpcType.HANDSHAKE, BitServerHandshake.class) .add(RpcType.REQ_RECORD_BATCH, FragmentRecordBatch.class, RpcType.ACK, Ack.class) .build(); - - public static int RPC_VERSION = 1; - + + public static int RPC_VERSION = 2; + public static final Response OK = new Response(RpcType.ACK, Acks.OK); } http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/496b5d0a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserRpcConfig.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserRpcConfig.java b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserRpcConfig.java index be5bb8b..56389b6 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserRpcConfig.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserRpcConfig.java @@ -28,13 +28,13 @@ import org.apache.drill.exec.rpc.RpcConfig; public class UserRpcConfig { static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(UserRpcConfig.class); - + public static RpcConfig MAPPING = RpcConfig.newBuilder("USER-RPC-MAPPING") // .add(RpcType.HANDSHAKE, UserToBitHandshake.class, RpcType.HANDSHAKE, BitToUserHandshake.class) //user to bit. .add(RpcType.RUN_QUERY, RunQuery.class, RpcType.QUERY_HANDLE, QueryId.class) //user to bit .add(RpcType.CANCEL_QUERY, QueryId.class, RpcType.ACK, Ack.class) //user to bit .add(RpcType.QUERY_RESULT, QueryResult.class, RpcType.ACK, Ack.class) //bit to user .build(); - - public static int RPC_VERSION = 1; + + public static int RPC_VERSION = 2; }
