[09/16] phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs
PHOENIX-1653 Support separate clusters for MR jobs Add support for the input and output formats of a Phoenix MapReduce job to point to separate clusters using override configuration settings. Defaults to existing behavior (HConstants.ZOOKEEPER_QUORUM) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/7de8ee1e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/7de8ee1e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/7de8ee1e Branch: refs/heads/4.x-HBase-1.x Commit: 7de8ee1e914f5e0008ca9d983869757e4ca92b78 Parents: f4180fa Author: gjacoby Authored: Fri Feb 27 16:49:14 2015 -0800 Committer: Gabriel Reid Committed: Tue Mar 24 20:07:52 2015 +0100 -- .../phoenix/mapreduce/PhoenixInputFormat.java | 15 ++-- .../phoenix/mapreduce/PhoenixRecordWriter.java | 2 +- .../phoenix/mapreduce/index/IndexTool.java | 2 +- .../index/PhoenixIndexImportMapper.java | 2 +- .../phoenix/mapreduce/util/ConnectionUtil.java | 88 ++-- .../util/PhoenixConfigurationUtil.java | 72 ++-- .../mapreduce/util/PhoenixMapReduceUtil.java| 22 - .../util/PhoenixConfigurationUtilTest.java | 60 - .../pig/util/QuerySchemaParserFunction.java | 2 +- .../pig/util/SqlQueryToColumnInfoFunction.java | 2 +- 10 files changed, 219 insertions(+), 48 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java index a83b9ae..31759b4 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java @@ -98,15 +98,16 @@ public class PhoenixInputFormat extends InputFormat extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java index 4d26bf4..5843076 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java @@ -46,7 +46,7 @@ public class PhoenixRecordWriter extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java index d93ef9c..300f575 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java @@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool { final String qDataTable = SchemaUtil.getTableName(schemaName, dataTable); final String qIndexTable = SchemaUtil.getTableName(schemaName, indexTable); -connection = ConnectionUtil.getConnection(configuration); +connection = ConnectionUtil.getInputConnection(configuration); if(!isValidIndexTable(connection, dataTable, indexTable)) { throw new IllegalArgumentException(String.format(" %s is not an index table for %s ",qIndexTable,qDataTable)); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java index 7bf4bfc..30f6dc0 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java @@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/ConnectionUtil.jav
[09/31] phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs
PHOENIX-1653 Support separate clusters for MR jobs Add support for the input and output formats of a Phoenix MapReduce job to point to separate clusters using override configuration settings. Defaults to existing behavior (HConstants.ZOOKEEPER_QUORUM) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/7de8ee1e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/7de8ee1e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/7de8ee1e Branch: refs/heads/4.x-HBase-1.x Commit: 7de8ee1e914f5e0008ca9d983869757e4ca92b78 Parents: f4180fa Author: gjacoby Authored: Fri Feb 27 16:49:14 2015 -0800 Committer: Gabriel Reid Committed: Tue Mar 24 20:07:52 2015 +0100 -- .../phoenix/mapreduce/PhoenixInputFormat.java | 15 ++-- .../phoenix/mapreduce/PhoenixRecordWriter.java | 2 +- .../phoenix/mapreduce/index/IndexTool.java | 2 +- .../index/PhoenixIndexImportMapper.java | 2 +- .../phoenix/mapreduce/util/ConnectionUtil.java | 88 ++-- .../util/PhoenixConfigurationUtil.java | 72 ++-- .../mapreduce/util/PhoenixMapReduceUtil.java| 22 - .../util/PhoenixConfigurationUtilTest.java | 60 - .../pig/util/QuerySchemaParserFunction.java | 2 +- .../pig/util/SqlQueryToColumnInfoFunction.java | 2 +- 10 files changed, 219 insertions(+), 48 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java index a83b9ae..31759b4 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java @@ -98,15 +98,16 @@ public class PhoenixInputFormat extends InputFormat extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java index 4d26bf4..5843076 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java @@ -46,7 +46,7 @@ public class PhoenixRecordWriter extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java index d93ef9c..300f575 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java @@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool { final String qDataTable = SchemaUtil.getTableName(schemaName, dataTable); final String qIndexTable = SchemaUtil.getTableName(schemaName, indexTable); -connection = ConnectionUtil.getConnection(configuration); +connection = ConnectionUtil.getInputConnection(configuration); if(!isValidIndexTable(connection, dataTable, indexTable)) { throw new IllegalArgumentException(String.format(" %s is not an index table for %s ",qIndexTable,qDataTable)); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java index 7bf4bfc..30f6dc0 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java @@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/ConnectionUtil.jav
phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs
Repository: phoenix Updated Branches: refs/heads/master 673847109 -> ab9c9283e PHOENIX-1653 Support separate clusters for MR jobs Add support for the input and output formats of a Phoenix MapReduce job to point to separate clusters using override configuration settings. Defaults to existing behavior (HConstants.ZOOKEEPER_QUORUM) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/ab9c9283 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/ab9c9283 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/ab9c9283 Branch: refs/heads/master Commit: ab9c9283eca692b6f3ef03a598f4c012e63ef83a Parents: 6738471 Author: gjacoby Authored: Fri Feb 27 16:49:14 2015 -0800 Committer: Gabriel Reid Committed: Tue Mar 24 20:08:08 2015 +0100 -- .../phoenix/mapreduce/PhoenixInputFormat.java | 15 ++-- .../phoenix/mapreduce/PhoenixRecordWriter.java | 2 +- .../phoenix/mapreduce/index/IndexTool.java | 2 +- .../index/PhoenixIndexImportMapper.java | 2 +- .../phoenix/mapreduce/util/ConnectionUtil.java | 88 ++-- .../util/PhoenixConfigurationUtil.java | 72 ++-- .../mapreduce/util/PhoenixMapReduceUtil.java| 22 - .../util/PhoenixConfigurationUtilTest.java | 60 - .../pig/util/QuerySchemaParserFunction.java | 2 +- .../pig/util/SqlQueryToColumnInfoFunction.java | 2 +- 10 files changed, 219 insertions(+), 48 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java index a83b9ae..31759b4 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java @@ -98,15 +98,16 @@ public class PhoenixInputFormat extends InputFormat extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java index 4d26bf4..5843076 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java @@ -46,7 +46,7 @@ public class PhoenixRecordWriter extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java index d93ef9c..300f575 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java @@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool { final String qDataTable = SchemaUtil.getTableName(schemaName, dataTable); final String qIndexTable = SchemaUtil.getTableName(schemaName, indexTable); -connection = ConnectionUtil.getConnection(configuration); +connection = ConnectionUtil.getInputConnection(configuration); if(!isValidIndexTable(connection, dataTable, indexTable)) { throw new IllegalArgumentException(String.format(" %s is not an index table for %s ",qIndexTable,qDataTable)); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java index 7bf4bfc..30f6dc0 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java @@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/pho
phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.x f4180fa40 -> 7de8ee1e9 PHOENIX-1653 Support separate clusters for MR jobs Add support for the input and output formats of a Phoenix MapReduce job to point to separate clusters using override configuration settings. Defaults to existing behavior (HConstants.ZOOKEEPER_QUORUM) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/7de8ee1e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/7de8ee1e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/7de8ee1e Branch: refs/heads/4.x-HBase-1.x Commit: 7de8ee1e914f5e0008ca9d983869757e4ca92b78 Parents: f4180fa Author: gjacoby Authored: Fri Feb 27 16:49:14 2015 -0800 Committer: Gabriel Reid Committed: Tue Mar 24 20:07:52 2015 +0100 -- .../phoenix/mapreduce/PhoenixInputFormat.java | 15 ++-- .../phoenix/mapreduce/PhoenixRecordWriter.java | 2 +- .../phoenix/mapreduce/index/IndexTool.java | 2 +- .../index/PhoenixIndexImportMapper.java | 2 +- .../phoenix/mapreduce/util/ConnectionUtil.java | 88 ++-- .../util/PhoenixConfigurationUtil.java | 72 ++-- .../mapreduce/util/PhoenixMapReduceUtil.java| 22 - .../util/PhoenixConfigurationUtilTest.java | 60 - .../pig/util/QuerySchemaParserFunction.java | 2 +- .../pig/util/SqlQueryToColumnInfoFunction.java | 2 +- 10 files changed, 219 insertions(+), 48 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java index a83b9ae..31759b4 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java @@ -98,15 +98,16 @@ public class PhoenixInputFormat extends InputFormat extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java index 4d26bf4..5843076 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java @@ -46,7 +46,7 @@ public class PhoenixRecordWriter extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java index d93ef9c..300f575 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java @@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool { final String qDataTable = SchemaUtil.getTableName(schemaName, dataTable); final String qIndexTable = SchemaUtil.getTableName(schemaName, indexTable); -connection = ConnectionUtil.getConnection(configuration); +connection = ConnectionUtil.getInputConnection(configuration); if(!isValidIndexTable(connection, dataTable, indexTable)) { throw new IllegalArgumentException(String.format(" %s is not an index table for %s ",qIndexTable,qDataTable)); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java index 7bf4bfc..30f6dc0 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java @@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/blo
phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs
Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 c92de2749 -> af0d65a0a PHOENIX-1653 Support separate clusters for MR jobs Add support for the input and output formats of a Phoenix MapReduce job to point to separate clusters using override configuration settings. Defaults to existing behavior (HConstants.ZOOKEEPER_QUORUM) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/af0d65a0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/af0d65a0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/af0d65a0 Branch: refs/heads/4.x-HBase-0.98 Commit: af0d65a0abdbb8dc73d766a15e3ffa0e6d854d13 Parents: c92de27 Author: gjacoby Authored: Fri Feb 27 16:49:14 2015 -0800 Committer: Gabriel Reid Committed: Tue Mar 24 19:40:21 2015 +0100 -- .../phoenix/mapreduce/PhoenixInputFormat.java | 15 ++-- .../phoenix/mapreduce/PhoenixRecordWriter.java | 2 +- .../phoenix/mapreduce/index/IndexTool.java | 2 +- .../index/PhoenixIndexImportMapper.java | 2 +- .../phoenix/mapreduce/util/ConnectionUtil.java | 88 ++-- .../util/PhoenixConfigurationUtil.java | 72 ++-- .../mapreduce/util/PhoenixMapReduceUtil.java| 22 - .../util/PhoenixConfigurationUtilTest.java | 60 - .../pig/util/QuerySchemaParserFunction.java | 2 +- .../pig/util/SqlQueryToColumnInfoFunction.java | 2 +- 10 files changed, 219 insertions(+), 48 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java index a83b9ae..31759b4 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java @@ -98,15 +98,16 @@ public class PhoenixInputFormat extends InputFormat extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java index 4d26bf4..5843076 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java @@ -46,7 +46,7 @@ public class PhoenixRecordWriter extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java index d93ef9c..300f575 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java @@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool { final String qDataTable = SchemaUtil.getTableName(schemaName, dataTable); final String qIndexTable = SchemaUtil.getTableName(schemaName, indexTable); -connection = ConnectionUtil.getConnection(configuration); +connection = ConnectionUtil.getInputConnection(configuration); if(!isValidIndexTable(connection, dataTable, indexTable)) { throw new IllegalArgumentException(String.format(" %s is not an index table for %s ",qIndexTable,qDataTable)); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java index 7bf4bfc..30f6dc0 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java @@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/b