You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ra...@apache.org on 2017/02/15 06:37:22 UTC
phoenix git commit: PHOENIX-3360 Secondary index configuration is
wrong(William Yang)
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 <ra...@apache.org>
Authored: Wed Feb 15 12:20:07 2017 +0530
Committer: Rajeshbabu Chintaguntla <ra...@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.