Repository: phoenix Updated Branches: refs/heads/master 799d217f6 -> 18a86b65f
PHOENIX-3360 Secondary index configuration is wrong(William Yang) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/18a86b65 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/18a86b65 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/18a86b65 Branch: refs/heads/master Commit: 18a86b65fc6a6feab88fac740e1756bc571dc68b Parents: 799d217 Author: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Authored: Wed Feb 15 12:20:07 2017 +0530 Committer: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Committed: Wed Feb 15 12:20:07 2017 +0530 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/hbase/index/Indexer.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/18a86b65/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/Indexer.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/Indexer.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/Indexer.java index 0d051be..c482cbd 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/Indexer.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/Indexer.java @@ -46,6 +46,8 @@ import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.coprocessor.BaseRegionObserver; import org.apache.hadoop.hbase.coprocessor.ObserverContext; import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; +import org.apache.hadoop.hbase.ipc.RpcControllerFactory; +import org.apache.hadoop.hbase.ipc.controller.ServerRpcControllerFactory; import org.apache.hadoop.hbase.regionserver.InternalScanner; import org.apache.hadoop.hbase.regionserver.KeyValueScanner; import org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress; @@ -144,6 +146,8 @@ public class Indexer extends BaseRegionObserver { try { final RegionCoprocessorEnvironment env = (RegionCoprocessorEnvironment) e; this.environment = env; + env.getConfiguration().setClass(RpcControllerFactory.CUSTOM_CONTROLLER_CONF_KEY, + ServerRpcControllerFactory.class, RpcControllerFactory.class); String serverName = env.getRegionServerServices().getServerName().getServerName(); if (env.getConfiguration().getBoolean(CHECK_VERSION_CONF_KEY, true)) { // make sure the right version <-> combinations are allowed.