You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ka...@apache.org on 2019/10/12 22:51:26 UTC
[phoenix] branch master updated: PHOENIX-5514 Index read repair
should use index rpc handlers
This is an automated email from the ASF dual-hosted git repository.
kadir pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/master by this push:
new 13046b1 PHOENIX-5514 Index read repair should use index rpc handlers
13046b1 is described below
commit 13046b1a22c414d6e4e0b347d09593393de6f7df
Author: Gokcen Iskender <gi...@salesforce.com>
AuthorDate: Thu Oct 10 12:58:59 2019 -0700
PHOENIX-5514 Index read repair should use index rpc handlers
Signed-off-by: Kadir <ko...@salesforce.com>
---
.../src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java b/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java
index 77771c9..dd95c8e 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java
@@ -278,7 +278,7 @@ public class GlobalIndexChecker implements RegionCoprocessor, RegionObserver {
singleRowIndexScan = new Scan(scan);
byte[] dataTableName = scan.getAttribute(PHYSICAL_DATA_TABLE_NAME);
byte[] indexTableName = region.getRegionInfo().getTable().getName();
- dataHTable = ServerUtil.ConnectionFactory.getConnection(ServerUtil.ConnectionType.DEFAULT_SERVER_CONNECTION,
+ dataHTable = ServerUtil.ConnectionFactory.getConnection(ServerUtil.ConnectionType.INDEX_WRITER_CONNECTION,
env).getTable(TableName.valueOf(dataTableName));
if (indexMaintainer == null) {
byte[] md = scan.getAttribute(PhoenixIndexCodec.INDEX_PROTO_MD);