Build failed in Jenkins: Phoenix-4.x-HBase-1.1 #120

2016-07-12 Thread Apache Jenkins Server 
See 

Changes:

[tdsilva] PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if 
bulkload

--
[...truncated 703 lines...]
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 826.534 sec - 
in org.apache.phoenix.end2end.index.MutableIndexIT

Results :

Tests run: 1194, Failures: 0, Errors: 0, Skipped: 5

[INFO] 
[INFO] --- maven-failsafe-plugin:2.19.1:integration-test 
(HBaseManagedTimeTableReuseTest) @ phoenix-core ---

---
 T E S T S
---
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.AlterSessionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.065 sec - in 
org.apache.phoenix.end2end.AlterSessionIT
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.718 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.AutoCommitIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.436 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.353 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 18.926 sec - 
in org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 30.205 sec - 
in org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 18.531 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.797 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 20.134 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.095 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.09 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.796 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 51.899 sec - 
in org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.253 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.439 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.61 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.36 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.134 sec - in 
org.apache.phoenix.end2end.PrimitiveTypeIT
Running org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.425 sec - in 
org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.RTrimFunctionIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.64 sec - in 
org.apache.phoenix.end2end.DistinctPrefixFilterIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 74.161 sec - 
in org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.353 sec - in 
org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.ReverseFunctionIT
Tests run: 2, Failures: 0, Errors: 0, Skippe

Build failed in Jenkins: Phoenix | 4.x-HBase-0.98 #1231

2016-07-12 Thread Apache Jenkins Server 
See 

Changes:

[tdsilva] PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if 
bulkload

--
[...truncated 702 lines...]
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 79.436 sec - 
in org.apache.phoenix.tx.TxCheckpointIT
Tests run: 128, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 501.135 sec - 
in org.apache.phoenix.end2end.index.IndexIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 560.583 sec - 
in org.apache.phoenix.end2end.index.MutableIndexIT

Results :

Tests run: 1194, Failures: 0, Errors: 0, Skipped: 5

[INFO] 
[INFO] --- maven-failsafe-plugin:2.19.1:integration-test 
(HBaseManagedTimeTableReuseTest) @ phoenix-core ---

---
 T E S T S
---
Running org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.504 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.AutoCommitIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.61 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.687 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.785 sec - in 
org.apache.phoenix.end2end.ArrayFillFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.226 sec - in 
org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.752 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.355 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.755 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.122 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 17.63 sec - in 
org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.213 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.52 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.63 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.208 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.37 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.603 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.862 sec - in 
org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.344 sec - in 
org.apache.phoenix.end2end.PrimitiveTypeIT
Running org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.RTrimFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.147 sec - 
in org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.784 sec - in 
org.apache.phoenix.end2end.RTrimFunctionIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.353 sec - 
in org.apache.phoenix.end2end.NthValueFunctionIT
Running org.apache.phoenix.end2end.Reve

Build failed in Jenkins: Phoenix-4.x-HBase-1.0 #567

2016-07-12 Thread Apache Jenkins Server 
See 

Changes:

[tdsilva] PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if

--
[...truncated 729 lines...]
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.808 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.129 sec - 
in org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.237 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.173 sec - 
in org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.086 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.767 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.102 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.1 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.458 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.356 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.124 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.474 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.12 sec - in 
org.apache.phoenix.end2end.PrimitiveTypeIT
Running org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Running org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.278 sec - in 
org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.RTrimFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 28.894 sec - 
in org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.364 sec - in 
org.apache.phoenix.end2end.RTrimFunctionIT
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.46 sec - in 
org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.ReverseFunctionIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.185 sec - 
in org.apache.phoenix.end2end.NthValueFunctionIT
Running org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.065 sec - in 
org.apache.phoenix.end2end.ReadOnlyIT
Running org.apache.phoenix.end2end.SerialIteratorsIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.64 sec - in 
org.apache.phoenix.end2end.SerialIteratorsIT
Running org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.3 sec - in 
org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.381 sec - in 
org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT
Running org.apache.phoenix.end2end.SortOrderIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.067 sec - in 
org.apache.phoenix.end2end.ReverseFunctionIT
Running org.apache.phoenix.end2end.StatementHintsIT
Running org.apache.phoenix.end2end.SignFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.278 sec - in 
org.apache.phoenix.end2end.SignFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.345 sec - in 
org.apache.phoenix.end2end.StatementHintsIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.105 sec - in 
org.apache.phoenix.end2end.DistinctPrefixFilterIT
Running org.apache.phoenix.end2end.TimezoneOffsetFunctionIT
Running org.apache.phoenix.end2end.StringToArrayFunctionIT
Running org.apache.phoenix.end2

phoenix git commit: PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has error (addendum) (Simon Wang)

2016-07-12 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/master e060a131b -> 776af74af


PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has 
error (addendum) (Simon Wang)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/776af74a
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/776af74a
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/776af74a

Branch: refs/heads/master
Commit: 776af74af3d1c9c1d487166d6c44713888de9c5e
Parents: e060a13
Author: Simon Wang 
Authored: Tue Jul 12 11:38:21 2016 -0700
Committer: Thomas D'Silva 
Committed: Tue Jul 12 22:08:43 2016 -0700

--
 .../org/apache/phoenix/end2end/IndexToolIT.java | 14 -
 .../phoenix/mapreduce/index/IndexTool.java  | 16 +++---
 .../phoenix/mapreduce/index/IndexToolUtil.java  |  8 ++-
 .../index/PhoenixIndexImportDirectReducer.java  | 60 
 .../index/PhoenixIndexImportMapper.java |  7 ++-
 .../index/PhoenixIndexToolReducer.java  | 60 
 6 files changed, 90 insertions(+), 75 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/776af74a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
index cb013c8..c66fea3 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
@@ -37,6 +37,7 @@ import java.util.UUID;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.phoenix.mapreduce.index.IndexTool;
+import org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.query.QueryServicesOptions;
 import org.apache.phoenix.util.PropertiesUtil;
@@ -126,11 +127,16 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {
 if (transactional) {
 // insert two rows in another connection without committing so 
that they are not visible to other transactions
 try (Connection conn2 = DriverManager.getConnection(getUrl(), 
props)) {
-PreparedStatement stmt2 = 
conn.prepareStatement(upsertQuery);
+conn2.setAutoCommit(false);
+PreparedStatement stmt2 = 
conn2.prepareStatement(upsertQuery);
 upsertRow(stmt2, 5);
 upsertRow(stmt2, 6);
 ResultSet rs = conn.createStatement().executeQuery("SELECT 
count(*) from "+fullTableName);
 assertTrue(rs.next());
+assertEquals("Unexpected row count ", 2, rs.getInt(1));
+assertFalse(rs.next());
+rs = conn2.createStatement().executeQuery("SELECT count(*) 
from "+fullTableName);
+assertTrue(rs.next());
 assertEquals("Unexpected row count ", 4, rs.getInt(1));
 assertFalse(rs.next());
 }
@@ -156,8 +162,10 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {

 //run the index MR job.
 final IndexTool indexingTool = new IndexTool();
-indexingTool.setConf(new 
Configuration(getUtility().getConfiguration()));
-
+Configuration conf = new 
Configuration(getUtility().getConfiguration());
+conf.set(QueryServices.TRANSACTIONS_ENABLED, 
Boolean.TRUE.toString());
+indexingTool.setConf(conf);
+
 final String[] cmdArgs = getArgValues(schemaName, dataTable, 
indxTable, directApi);
 int status = indexingTool.run(cmdArgs);
 assertEquals(0, status);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/776af74a/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 1b1f0fb..34c9013 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
@@ -244,15 +244,13 @@ public class IndexTool extends Configured implements Tool 
{
 
 boolean useDirectApi = 
cmdLine.hasOption(DIRECT_API_OPTION.getOpt());
 if (useDirectApi) {
-job.setMapperClass(PhoenixIndexImportDirectMapper.class);
 configureSubmittableJobUsingD

phoenix git commit: PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has error (addendum) (Simon Wang)

2016-07-12 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 e2b4e57d7 -> d3204f7d1


PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has 
error (addendum) (Simon Wang)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/d3204f7d
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/d3204f7d
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/d3204f7d

Branch: refs/heads/4.x-HBase-1.1
Commit: d3204f7d133ecabe84991e36803a9c3f1a2d8507
Parents: e2b4e57
Author: Simon Wang 
Authored: Tue Jul 12 11:38:21 2016 -0700
Committer: Thomas D'Silva 
Committed: Tue Jul 12 22:11:14 2016 -0700

--
 .../org/apache/phoenix/end2end/IndexToolIT.java | 14 -
 .../phoenix/mapreduce/index/IndexTool.java  | 16 +++---
 .../phoenix/mapreduce/index/IndexToolUtil.java  |  8 ++-
 .../index/PhoenixIndexImportDirectReducer.java  | 60 
 .../index/PhoenixIndexImportMapper.java |  7 ++-
 .../index/PhoenixIndexToolReducer.java  | 60 
 6 files changed, 90 insertions(+), 75 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/d3204f7d/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
index cb013c8..c66fea3 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
@@ -37,6 +37,7 @@ import java.util.UUID;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.phoenix.mapreduce.index.IndexTool;
+import org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.query.QueryServicesOptions;
 import org.apache.phoenix.util.PropertiesUtil;
@@ -126,11 +127,16 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {
 if (transactional) {
 // insert two rows in another connection without committing so 
that they are not visible to other transactions
 try (Connection conn2 = DriverManager.getConnection(getUrl(), 
props)) {
-PreparedStatement stmt2 = 
conn.prepareStatement(upsertQuery);
+conn2.setAutoCommit(false);
+PreparedStatement stmt2 = 
conn2.prepareStatement(upsertQuery);
 upsertRow(stmt2, 5);
 upsertRow(stmt2, 6);
 ResultSet rs = conn.createStatement().executeQuery("SELECT 
count(*) from "+fullTableName);
 assertTrue(rs.next());
+assertEquals("Unexpected row count ", 2, rs.getInt(1));
+assertFalse(rs.next());
+rs = conn2.createStatement().executeQuery("SELECT count(*) 
from "+fullTableName);
+assertTrue(rs.next());
 assertEquals("Unexpected row count ", 4, rs.getInt(1));
 assertFalse(rs.next());
 }
@@ -156,8 +162,10 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {

 //run the index MR job.
 final IndexTool indexingTool = new IndexTool();
-indexingTool.setConf(new 
Configuration(getUtility().getConfiguration()));
-
+Configuration conf = new 
Configuration(getUtility().getConfiguration());
+conf.set(QueryServices.TRANSACTIONS_ENABLED, 
Boolean.TRUE.toString());
+indexingTool.setConf(conf);
+
 final String[] cmdArgs = getArgValues(schemaName, dataTable, 
indxTable, directApi);
 int status = indexingTool.run(cmdArgs);
 assertEquals(0, status);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/d3204f7d/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 1b1f0fb..34c9013 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
@@ -244,15 +244,13 @@ public class IndexTool extends Configured implements Tool 
{
 
 boolean useDirectApi = 
cmdLine.hasOption(DIRECT_API_OPTION.getOpt());
 if (useDirectApi) {
-job.setMapperClass(PhoenixIndexImportDirectMapper.class);
 configureSubmit

phoenix git commit: PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has error (addendum) (Simon Wang)

2016-07-12 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 a67f74d58 -> 0848e3d64


PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has 
error (addendum) (Simon Wang)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/0848e3d6
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/0848e3d6
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/0848e3d6

Branch: refs/heads/4.x-HBase-0.98
Commit: 0848e3d64b029efa34e9e9ac338d975ba30ea28e
Parents: a67f74d
Author: Simon Wang 
Authored: Tue Jul 12 11:38:21 2016 -0700
Committer: Thomas D'Silva 
Committed: Tue Jul 12 22:11:02 2016 -0700

--
 .../org/apache/phoenix/end2end/IndexToolIT.java | 14 -
 .../phoenix/mapreduce/index/IndexTool.java  | 16 +++---
 .../phoenix/mapreduce/index/IndexToolUtil.java  |  8 ++-
 .../index/PhoenixIndexImportDirectReducer.java  | 60 
 .../index/PhoenixIndexImportMapper.java |  7 ++-
 .../index/PhoenixIndexToolReducer.java  | 60 
 6 files changed, 90 insertions(+), 75 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/0848e3d6/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
index cb013c8..c66fea3 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
@@ -37,6 +37,7 @@ import java.util.UUID;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.phoenix.mapreduce.index.IndexTool;
+import org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.query.QueryServicesOptions;
 import org.apache.phoenix.util.PropertiesUtil;
@@ -126,11 +127,16 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {
 if (transactional) {
 // insert two rows in another connection without committing so 
that they are not visible to other transactions
 try (Connection conn2 = DriverManager.getConnection(getUrl(), 
props)) {
-PreparedStatement stmt2 = 
conn.prepareStatement(upsertQuery);
+conn2.setAutoCommit(false);
+PreparedStatement stmt2 = 
conn2.prepareStatement(upsertQuery);
 upsertRow(stmt2, 5);
 upsertRow(stmt2, 6);
 ResultSet rs = conn.createStatement().executeQuery("SELECT 
count(*) from "+fullTableName);
 assertTrue(rs.next());
+assertEquals("Unexpected row count ", 2, rs.getInt(1));
+assertFalse(rs.next());
+rs = conn2.createStatement().executeQuery("SELECT count(*) 
from "+fullTableName);
+assertTrue(rs.next());
 assertEquals("Unexpected row count ", 4, rs.getInt(1));
 assertFalse(rs.next());
 }
@@ -156,8 +162,10 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {

 //run the index MR job.
 final IndexTool indexingTool = new IndexTool();
-indexingTool.setConf(new 
Configuration(getUtility().getConfiguration()));
-
+Configuration conf = new 
Configuration(getUtility().getConfiguration());
+conf.set(QueryServices.TRANSACTIONS_ENABLED, 
Boolean.TRUE.toString());
+indexingTool.setConf(conf);
+
 final String[] cmdArgs = getArgValues(schemaName, dataTable, 
indxTable, directApi);
 int status = indexingTool.run(cmdArgs);
 assertEquals(0, status);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/0848e3d6/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 1b1f0fb..34c9013 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
@@ -244,15 +244,13 @@ public class IndexTool extends Configured implements Tool 
{
 
 boolean useDirectApi = 
cmdLine.hasOption(DIRECT_API_OPTION.getOpt());
 if (useDirectApi) {
-job.setMapperClass(PhoenixIndexImportDirectMapper.class);
 configureSubm

phoenix git commit: PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has error (addendum) (Simon Wang)

2016-07-12 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 dcbf5f838 -> 60dc45592


PHOENIX-3061 IndexTool marks index as ACTIVE and exit 0 even if bulkload has 
error (addendum) (Simon Wang)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/60dc4559
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/60dc4559
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/60dc4559

Branch: refs/heads/4.x-HBase-1.0
Commit: 60dc45592e84b6f048f163fa9732ab54554ee30c
Parents: dcbf5f8
Author: Simon Wang 
Authored: Tue Jul 12 11:38:21 2016 -0700
Committer: Thomas D'Silva 
Committed: Tue Jul 12 22:11:09 2016 -0700

--
 .../org/apache/phoenix/end2end/IndexToolIT.java | 14 -
 .../phoenix/mapreduce/index/IndexTool.java  | 16 +++---
 .../phoenix/mapreduce/index/IndexToolUtil.java  |  8 ++-
 .../index/PhoenixIndexImportDirectReducer.java  | 60 
 .../index/PhoenixIndexImportMapper.java |  7 ++-
 .../index/PhoenixIndexToolReducer.java  | 60 
 6 files changed, 90 insertions(+), 75 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/60dc4559/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
index cb013c8..c66fea3 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexToolIT.java
@@ -37,6 +37,7 @@ import java.util.UUID;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.phoenix.mapreduce.index.IndexTool;
+import org.apache.phoenix.mapreduce.util.PhoenixConfigurationUtil;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.query.QueryServicesOptions;
 import org.apache.phoenix.util.PropertiesUtil;
@@ -126,11 +127,16 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {
 if (transactional) {
 // insert two rows in another connection without committing so 
that they are not visible to other transactions
 try (Connection conn2 = DriverManager.getConnection(getUrl(), 
props)) {
-PreparedStatement stmt2 = 
conn.prepareStatement(upsertQuery);
+conn2.setAutoCommit(false);
+PreparedStatement stmt2 = 
conn2.prepareStatement(upsertQuery);
 upsertRow(stmt2, 5);
 upsertRow(stmt2, 6);
 ResultSet rs = conn.createStatement().executeQuery("SELECT 
count(*) from "+fullTableName);
 assertTrue(rs.next());
+assertEquals("Unexpected row count ", 2, rs.getInt(1));
+assertFalse(rs.next());
+rs = conn2.createStatement().executeQuery("SELECT count(*) 
from "+fullTableName);
+assertTrue(rs.next());
 assertEquals("Unexpected row count ", 4, rs.getInt(1));
 assertFalse(rs.next());
 }
@@ -156,8 +162,10 @@ public class IndexToolIT extends 
BaseOwnClusterHBaseManagedTimeIT {

 //run the index MR job.
 final IndexTool indexingTool = new IndexTool();
-indexingTool.setConf(new 
Configuration(getUtility().getConfiguration()));
-
+Configuration conf = new 
Configuration(getUtility().getConfiguration());
+conf.set(QueryServices.TRANSACTIONS_ENABLED, 
Boolean.TRUE.toString());
+indexingTool.setConf(conf);
+
 final String[] cmdArgs = getArgValues(schemaName, dataTable, 
indxTable, directApi);
 int status = indexingTool.run(cmdArgs);
 assertEquals(0, status);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/60dc4559/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 1b1f0fb..34c9013 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
@@ -244,15 +244,13 @@ public class IndexTool extends Configured implements Tool 
{
 
 boolean useDirectApi = 
cmdLine.hasOption(DIRECT_API_OPTION.getOpt());
 if (useDirectApi) {
-job.setMapperClass(PhoenixIndexImportDirectMapper.class);
 configureSubmit

Build failed in Jenkins: Phoenix | 4.x-HBase-0.98 #1230

2016-07-12 Thread Apache Jenkins Server 
See 

Changes:

[ankitsinghal59] PHOENIX-3045 Data regions in transition forever if RS holding 
them down

--
[...truncated 728 lines...]
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.997 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.138 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.482 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.918 sec - in 
org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 17.079 sec - 
in org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.455 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.236 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.73 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.749 sec - 
in org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.212 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.173 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.427 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.584 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.047 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.087 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.512 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.153 sec - in 
org.apache.phoenix.end2end.PrimitiveTypeIT
Running org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.556 sec - in 
org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.RTrimFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 45.144 sec - 
in org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.583 sec - in 
org.apache.phoenix.end2end.RTrimFunctionIT
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.331 sec - in 
org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.ReverseFunctionIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.889 sec - in 
org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.831 sec - in 
org.apache.phoenix.end2end.ReadOnlyIT
Running org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT
Running org.apache.phoenix.end2end.SerialIteratorsIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 21.021 sec - 
in org.apache.phoenix.end2end.NthValueFunctionIT
Running org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.059 sec - in 
org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 1, Failures: 0, Error

Build failed in Jenkins: Phoenix-4.x-HBase-1.0 #566

2016-07-12 Thread Apache Jenkins Server 
See 

Changes:

[ankitsinghal59] PHOENIX-3063 MutableIndexFailureIT is getting hanged in 
4.x-HBase-0.98

[ankitsinghal59] PHOENIX-3045 Data regions in transition forever if RS holding 
them down

--
[...truncated 719 lines...]
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.AlterSessionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.11 sec - in 
org.apache.phoenix.end2end.AlterSessionIT
Running org.apache.phoenix.end2end.AutoCommitIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.742 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.251 sec - in 
org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.501 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.941 sec - in 
org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.056 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.914 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.769 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.131 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.26 sec - in 
org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.082 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.831 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.344 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.415 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.351 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.583 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.155 sec - in 
org.apache.phoenix.end2end.PrimitiveTypeIT
Running org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.534 sec - in 
org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.RTrimFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 28.897 sec - 
in org.apache.phoenix.end2end.ArithmeticQueryIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.212 sec - in 
org.apache.phoenix.end2end.RTrimFunctionIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.275 sec - 
in org.apache.phoenix.end2end.NthValueFunctionIT
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.ReverseFunctionIT
Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.326 sec - in 
org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.224 sec - in 
org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.967 sec - in 
org.apache.phoenix.end2end.ReverseFunctionIT
Running org.apache.phoenix.end2end.SerialIteratorsIT
Running org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.185 sec - in 
org.apache

phoenix git commit: PHOENIX-3045 Data regions in transition forever if RS holding them down during drop index

2016-07-12 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 45f0004e0 -> a67f74d58


PHOENIX-3045 Data regions in transition forever if RS holding them down during 
drop index


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/a67f74d5
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/a67f74d5
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/a67f74d5

Branch: refs/heads/4.x-HBase-0.98
Commit: a67f74d58e80a19acbb81dc266bab1fffea9cfc3
Parents: 45f0004
Author: Ankit Singhal 
Authored: Tue Jul 12 23:12:52 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 23:12:52 2016 +0530

--
 .../org/apache/phoenix/hbase/index/Indexer.java |  15 +--
 .../phoenix/hbase/index/write/IndexWriter.java  |  14 +-
 .../hbase/index/write/RecoveryIndexWriter.java  | 134 +++
 .../phoenix/iterate/BaseResultIterators.java|   5 +-
 .../stats/StatisticsCollectorFactory.java   |  21 +--
 .../phoenix/schema/stats/StatisticsUtil.java|  27 
 6 files changed, 176 insertions(+), 40 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/a67f74d5/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 0aed2a6..2956470 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
@@ -34,7 +34,6 @@ import org.apache.hadoop.hbase.CoprocessorEnvironment;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionInfo;
 import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.KeyValue;
 import org.apache.hadoop.hbase.client.Delete;
 import org.apache.hadoop.hbase.client.Durability;
 import org.apache.hadoop.hbase.client.Mutation;
@@ -63,13 +62,13 @@ import 
org.apache.phoenix.hbase.index.write.IndexFailurePolicy;
 import org.apache.phoenix.hbase.index.write.IndexWriter;
 import org.apache.phoenix.hbase.index.write.recovery.PerRegionIndexWriteCache;
 import 
org.apache.phoenix.hbase.index.write.recovery.StoreFailuresInCachePolicy;
-import 
org.apache.phoenix.hbase.index.write.recovery.TrackingParallelWriterIndexCommitter;
 import org.apache.phoenix.trace.TracingUtils;
 import org.apache.phoenix.trace.util.NullSpan;
 import org.cloudera.htrace.Span;
 import org.cloudera.htrace.Trace;
 import org.cloudera.htrace.TraceScope;
-
+import org.apache.hadoop.hbase.KeyValue;
+import org.apache.phoenix.hbase.index.write.RecoveryIndexWriter;
 import com.google.common.collect.Multimap;
 
 /**
@@ -152,11 +151,6 @@ public class Indexer extends BaseRegionObserver {
 
 // setup the actual index writer
 this.writer = new IndexWriter(env, serverName + "-index-writer");
-
-// setup the recovery writer that does retries on the failed edits
-TrackingParallelWriterIndexCommitter recoveryCommmiter =
-new TrackingParallelWriterIndexCommitter();
-
 try {
   // get the specified failure policy. We only ever override it in 
tests, but we need to do it
   // here
@@ -165,10 +159,9 @@ public class Indexer extends BaseRegionObserver {
 StoreFailuresInCachePolicy.class, IndexFailurePolicy.class);
   IndexFailurePolicy policy =
   
policyClass.getConstructor(PerRegionIndexWriteCache.class).newInstance(failedIndexEdits);
-  LOG.debug("Setting up recovery writter with committer: " + 
recoveryCommmiter.getClass()
-  + " and failure policy: " + policy.getClass());
+  LOG.debug("Setting up recovery writter with failure policy: " + 
policy.getClass());
   recoveryWriter =
-  new IndexWriter(recoveryCommmiter, policy, env, serverName + 
"-recovery-writer");
+  new RecoveryIndexWriter(policy, env, serverName + 
"-recovery-writer");
 } catch (Exception ex) {
   throw new IOException("Could not instantiate recovery failure 
policy!", ex);
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/a67f74d5/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriter.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriter.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriter.java
index cbcec3b..831aa16 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriter.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriter.jav

[1/2] phoenix git commit: PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch

2016-07-12 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 4785a4a3b -> dcbf5f838


PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/69034a35
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/69034a35
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/69034a35

Branch: refs/heads/4.x-HBase-1.0
Commit: 69034a35807e1d20b5af38b7cc6dd99740e127b6
Parents: 4785a4a
Author: Ankit Singhal 
Authored: Tue Jul 12 23:01:20 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 23:01:20 2016 +0530

--
 .../apache/phoenix/compile/FromCompiler.java|  8 ++--
 .../phoenix/iterate/BaseResultIterators.java|  5 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 47 +++-
 .../org/apache/phoenix/schema/PTableImpl.java   |  6 +--
 4 files changed, 38 insertions(+), 28 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/69034a35/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
index 46e7d14..8e4d9aa 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
@@ -185,7 +185,7 @@ public class FromCompiler {
 if (htable != null) Closeables.closeQuietly(htable);
 }
 tableNode = NamedTableNode.create(null, baseTable, 
statement.getColumnDefs());
-return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1));
+return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1), false);
 }
 throw e;
 }
@@ -332,7 +332,7 @@ public class FromCompiler {
private final String alias;
 private final List schemas;
 
-   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes) 
throws SQLException  {
+   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes, 
boolean isNamespaceMapped) throws SQLException  {
super(connection, 0, false, udfParseNodes);
List families = 
Lists.newArrayListWithExpectedSize(table.getDynamicColumns().size());
for (ColumnDef def : table.getDynamicColumns()) {
@@ -345,8 +345,8 @@ public class FromCompiler {
 if (connection.getSchema() != null) {
 schema = schema != null ? schema : connection.getSchema();
 }
-PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
-scn == null ? HConstants.LATEST_TIMESTAMP : scn, families);
+   PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
+scn == null ? HConstants.LATEST_TIMESTAMP : scn, families, 
isNamespaceMapped);
theTable = this.addDynamicColumns(table.getDynamicColumns(), 
theTable);
alias = null;
tableRefs = ImmutableList.of(new TableRef(alias, theTable, 
timeStamp, !table.getDynamicColumns().isEmpty()));

http://git-wip-us.apache.org/repos/asf/phoenix/blob/69034a35/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
index 6f053bf..4a797b8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
@@ -80,6 +80,7 @@ import org.apache.phoenix.schema.PColumnFamily;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.IndexType;
 import org.apache.phoenix.schema.PTable.ViewType;
+import org.apache.phoenix.schema.PTableType;
 import org.apache.phoenix.schema.StaleRegionBoundaryCacheException;
 import org.apache.phoenix.schema.TableRef;
 import org.apache.phoenix.schema.stats.GuidePostsInfo;
@@ -359,7 +360,9 @@ public abstract class BaseResultIterators extends 
ExplainTable implements Result
 if (null == currentSCN) {
   currentSCN = HConstants.LATEST_TIMESTAMP;
 }
-tableStats = useStats() ? 
context.getConnection().getQueryServices().getTableStats(

[2/2] phoenix git commit: PHOENIX-3045 Data regions in transition forever if RS holding them down during drop index

2016-07-12 Thread ankit 
PHOENIX-3045 Data regions in transition forever if RS holding them down during 
drop index


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/dcbf5f83
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/dcbf5f83
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/dcbf5f83

Branch: refs/heads/4.x-HBase-1.0
Commit: dcbf5f83835327e1d9912d2e536918e9003a79ea
Parents: 69034a3
Author: Ankit Singhal 
Authored: Tue Jul 12 23:01:35 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 23:01:35 2016 +0530

--
 .../org/apache/phoenix/hbase/index/Indexer.java |  23 +---
 .../phoenix/hbase/index/write/IndexWriter.java  |  14 +-
 .../hbase/index/write/RecoveryIndexWriter.java  | 134 +++
 .../phoenix/iterate/BaseResultIterators.java|   5 +-
 .../stats/StatisticsCollectorFactory.java   |  21 +--
 .../phoenix/schema/stats/StatisticsUtil.java|  27 
 6 files changed, 178 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/dcbf5f83/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 6e5edee..a964373 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
@@ -24,11 +24,8 @@ import java.security.PrivilegedExceptionAction;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
-import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Set;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -38,7 +35,6 @@ import org.apache.hadoop.hbase.CoprocessorEnvironment;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionInfo;
 import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.KeyValue;
 import org.apache.hadoop.hbase.client.Delete;
 import org.apache.hadoop.hbase.client.Durability;
 import org.apache.hadoop.hbase.client.Mutation;
@@ -56,6 +52,9 @@ import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
 import org.apache.hadoop.hbase.security.User;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.hbase.util.Pair;
+import org.apache.htrace.Span;
+import org.apache.htrace.Trace;
+import org.apache.htrace.TraceScope;
 import org.apache.phoenix.hbase.index.builder.IndexBuildManager;
 import org.apache.phoenix.hbase.index.builder.IndexBuilder;
 import org.apache.phoenix.hbase.index.table.HTableInterfaceReference;
@@ -65,15 +64,11 @@ import org.apache.phoenix.hbase.index.util.VersionUtil;
 import org.apache.phoenix.hbase.index.wal.IndexedKeyValue;
 import org.apache.phoenix.hbase.index.write.IndexFailurePolicy;
 import org.apache.phoenix.hbase.index.write.IndexWriter;
+import org.apache.phoenix.hbase.index.write.RecoveryIndexWriter;
 import org.apache.phoenix.hbase.index.write.recovery.PerRegionIndexWriteCache;
 import 
org.apache.phoenix.hbase.index.write.recovery.StoreFailuresInCachePolicy;
-import 
org.apache.phoenix.hbase.index.write.recovery.TrackingParallelWriterIndexCommitter;
 import org.apache.phoenix.trace.TracingUtils;
 import org.apache.phoenix.trace.util.NullSpan;
-import org.apache.phoenix.util.IndexUtil;
-import org.apache.htrace.Span;
-import org.apache.htrace.Trace;
-import org.apache.htrace.TraceScope;
 
 import com.google.common.collect.Multimap;
 
@@ -157,11 +152,6 @@ public class Indexer extends BaseRegionObserver {
 
 // setup the actual index writer
 this.writer = new IndexWriter(env, serverName + "-index-writer");
-
-// setup the recovery writer that does retries on the failed edits
-TrackingParallelWriterIndexCommitter recoveryCommmiter =
-new TrackingParallelWriterIndexCommitter();
-
 try {
   // get the specified failure policy. We only ever override it in 
tests, but we need to do it
   // here
@@ -170,10 +160,9 @@ public class Indexer extends BaseRegionObserver {
 StoreFailuresInCachePolicy.class, IndexFailurePolicy.class);
   IndexFailurePolicy policy =
   
policyClass.getConstructor(PerRegionIndexWriteCache.class).newInstance(failedIndexEdits);
-  LOG.debug("Setting up recovery writter with committer: " + 
recoveryCommmiter.getClass()
-  + " and failure policy: " + policy.getClass());
+  LOG.debug("Setting up recovery writter with failure policy: " + 
policy.getClass());
   recoveryWriter =
-  new Inde

[2/2] phoenix git commit: PHOENIX-3045 Data regions in transition forever if RS holding them down during drop index

2016-07-12 Thread ankit 
PHOENIX-3045 Data regions in transition forever if RS holding them down during 
drop index


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e2b4e57d
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e2b4e57d
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e2b4e57d

Branch: refs/heads/4.x-HBase-1.1
Commit: e2b4e57d78e10f2f725ecc668c712016ac4b8b91
Parents: f034b08
Author: Ankit Singhal 
Authored: Tue Jul 12 22:58:16 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 22:58:16 2016 +0530

--
 .../org/apache/phoenix/hbase/index/Indexer.java |  23 +---
 .../phoenix/hbase/index/write/IndexWriter.java  |  14 +-
 .../hbase/index/write/RecoveryIndexWriter.java  | 134 +++
 .../phoenix/iterate/BaseResultIterators.java|   5 +-
 .../stats/StatisticsCollectorFactory.java   |  21 +--
 .../phoenix/schema/stats/StatisticsUtil.java|  27 
 6 files changed, 178 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/e2b4e57d/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 6e5edee..a964373 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
@@ -24,11 +24,8 @@ import java.security.PrivilegedExceptionAction;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
-import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Set;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -38,7 +35,6 @@ import org.apache.hadoop.hbase.CoprocessorEnvironment;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionInfo;
 import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.KeyValue;
 import org.apache.hadoop.hbase.client.Delete;
 import org.apache.hadoop.hbase.client.Durability;
 import org.apache.hadoop.hbase.client.Mutation;
@@ -56,6 +52,9 @@ import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
 import org.apache.hadoop.hbase.security.User;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.hbase.util.Pair;
+import org.apache.htrace.Span;
+import org.apache.htrace.Trace;
+import org.apache.htrace.TraceScope;
 import org.apache.phoenix.hbase.index.builder.IndexBuildManager;
 import org.apache.phoenix.hbase.index.builder.IndexBuilder;
 import org.apache.phoenix.hbase.index.table.HTableInterfaceReference;
@@ -65,15 +64,11 @@ import org.apache.phoenix.hbase.index.util.VersionUtil;
 import org.apache.phoenix.hbase.index.wal.IndexedKeyValue;
 import org.apache.phoenix.hbase.index.write.IndexFailurePolicy;
 import org.apache.phoenix.hbase.index.write.IndexWriter;
+import org.apache.phoenix.hbase.index.write.RecoveryIndexWriter;
 import org.apache.phoenix.hbase.index.write.recovery.PerRegionIndexWriteCache;
 import 
org.apache.phoenix.hbase.index.write.recovery.StoreFailuresInCachePolicy;
-import 
org.apache.phoenix.hbase.index.write.recovery.TrackingParallelWriterIndexCommitter;
 import org.apache.phoenix.trace.TracingUtils;
 import org.apache.phoenix.trace.util.NullSpan;
-import org.apache.phoenix.util.IndexUtil;
-import org.apache.htrace.Span;
-import org.apache.htrace.Trace;
-import org.apache.htrace.TraceScope;
 
 import com.google.common.collect.Multimap;
 
@@ -157,11 +152,6 @@ public class Indexer extends BaseRegionObserver {
 
 // setup the actual index writer
 this.writer = new IndexWriter(env, serverName + "-index-writer");
-
-// setup the recovery writer that does retries on the failed edits
-TrackingParallelWriterIndexCommitter recoveryCommmiter =
-new TrackingParallelWriterIndexCommitter();
-
 try {
   // get the specified failure policy. We only ever override it in 
tests, but we need to do it
   // here
@@ -170,10 +160,9 @@ public class Indexer extends BaseRegionObserver {
 StoreFailuresInCachePolicy.class, IndexFailurePolicy.class);
   IndexFailurePolicy policy =
   
policyClass.getConstructor(PerRegionIndexWriteCache.class).newInstance(failedIndexEdits);
-  LOG.debug("Setting up recovery writter with committer: " + 
recoveryCommmiter.getClass()
-  + " and failure policy: " + policy.getClass());
+  LOG.debug("Setting up recovery writter with failure policy: " + 
policy.getClass());
   recoveryWriter =
-  new Inde

[1/2] phoenix git commit: PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch

2016-07-12 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 424bd798b -> e2b4e57d7


PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/f034b08b
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f034b08b
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f034b08b

Branch: refs/heads/4.x-HBase-1.1
Commit: f034b08b671051ada2d939c49f514794a724ec36
Parents: 424bd79
Author: Ankit Singhal 
Authored: Tue Jul 12 22:57:53 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 22:57:53 2016 +0530

--
 .../apache/phoenix/compile/FromCompiler.java|  8 ++--
 .../phoenix/iterate/BaseResultIterators.java|  5 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 47 +++-
 .../org/apache/phoenix/schema/PTableImpl.java   |  6 +--
 4 files changed, 38 insertions(+), 28 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/f034b08b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
index 46e7d14..8e4d9aa 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
@@ -185,7 +185,7 @@ public class FromCompiler {
 if (htable != null) Closeables.closeQuietly(htable);
 }
 tableNode = NamedTableNode.create(null, baseTable, 
statement.getColumnDefs());
-return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1));
+return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1), false);
 }
 throw e;
 }
@@ -332,7 +332,7 @@ public class FromCompiler {
private final String alias;
 private final List schemas;
 
-   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes) 
throws SQLException  {
+   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes, 
boolean isNamespaceMapped) throws SQLException  {
super(connection, 0, false, udfParseNodes);
List families = 
Lists.newArrayListWithExpectedSize(table.getDynamicColumns().size());
for (ColumnDef def : table.getDynamicColumns()) {
@@ -345,8 +345,8 @@ public class FromCompiler {
 if (connection.getSchema() != null) {
 schema = schema != null ? schema : connection.getSchema();
 }
-PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
-scn == null ? HConstants.LATEST_TIMESTAMP : scn, families);
+   PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
+scn == null ? HConstants.LATEST_TIMESTAMP : scn, families, 
isNamespaceMapped);
theTable = this.addDynamicColumns(table.getDynamicColumns(), 
theTable);
alias = null;
tableRefs = ImmutableList.of(new TableRef(alias, theTable, 
timeStamp, !table.getDynamicColumns().isEmpty()));

http://git-wip-us.apache.org/repos/asf/phoenix/blob/f034b08b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
index 6f053bf..4a797b8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
@@ -80,6 +80,7 @@ import org.apache.phoenix.schema.PColumnFamily;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.IndexType;
 import org.apache.phoenix.schema.PTable.ViewType;
+import org.apache.phoenix.schema.PTableType;
 import org.apache.phoenix.schema.StaleRegionBoundaryCacheException;
 import org.apache.phoenix.schema.TableRef;
 import org.apache.phoenix.schema.stats.GuidePostsInfo;
@@ -359,7 +360,9 @@ public abstract class BaseResultIterators extends 
ExplainTable implements Result
 if (null == currentSCN) {
   currentSCN = HConstants.LATEST_TIMESTAMP;
 }
-tableStats = useStats() ? 
context.getConnection().getQueryServices().getTableStats(

[2/2] phoenix git commit: PHOENIX-3045 Data regions in transition forever if RS holding them down during drop index

2016-07-12 Thread ankit 
PHOENIX-3045 Data regions in transition forever if RS holding them down during 
drop index


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e060a131
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e060a131
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e060a131

Branch: refs/heads/master
Commit: e060a131bd7cc94e860b70e0698c7d2d9802ddc9
Parents: 52d639f
Author: Ankit Singhal 
Authored: Tue Jul 12 22:55:23 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 22:55:23 2016 +0530

--
 .../org/apache/phoenix/hbase/index/Indexer.java |  23 +---
 .../phoenix/hbase/index/write/IndexWriter.java  |  14 +-
 .../hbase/index/write/RecoveryIndexWriter.java  | 134 +++
 .../phoenix/iterate/BaseResultIterators.java|   5 +-
 .../stats/StatisticsCollectorFactory.java   |  21 +--
 .../phoenix/schema/stats/StatisticsUtil.java|  27 
 6 files changed, 178 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/e060a131/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 6e5edee..a964373 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
@@ -24,11 +24,8 @@ import java.security.PrivilegedExceptionAction;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
-import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Set;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -38,7 +35,6 @@ import org.apache.hadoop.hbase.CoprocessorEnvironment;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionInfo;
 import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.KeyValue;
 import org.apache.hadoop.hbase.client.Delete;
 import org.apache.hadoop.hbase.client.Durability;
 import org.apache.hadoop.hbase.client.Mutation;
@@ -56,6 +52,9 @@ import org.apache.hadoop.hbase.regionserver.wal.WALEdit;
 import org.apache.hadoop.hbase.security.User;
 import org.apache.hadoop.hbase.util.Bytes;
 import org.apache.hadoop.hbase.util.Pair;
+import org.apache.htrace.Span;
+import org.apache.htrace.Trace;
+import org.apache.htrace.TraceScope;
 import org.apache.phoenix.hbase.index.builder.IndexBuildManager;
 import org.apache.phoenix.hbase.index.builder.IndexBuilder;
 import org.apache.phoenix.hbase.index.table.HTableInterfaceReference;
@@ -65,15 +64,11 @@ import org.apache.phoenix.hbase.index.util.VersionUtil;
 import org.apache.phoenix.hbase.index.wal.IndexedKeyValue;
 import org.apache.phoenix.hbase.index.write.IndexFailurePolicy;
 import org.apache.phoenix.hbase.index.write.IndexWriter;
+import org.apache.phoenix.hbase.index.write.RecoveryIndexWriter;
 import org.apache.phoenix.hbase.index.write.recovery.PerRegionIndexWriteCache;
 import 
org.apache.phoenix.hbase.index.write.recovery.StoreFailuresInCachePolicy;
-import 
org.apache.phoenix.hbase.index.write.recovery.TrackingParallelWriterIndexCommitter;
 import org.apache.phoenix.trace.TracingUtils;
 import org.apache.phoenix.trace.util.NullSpan;
-import org.apache.phoenix.util.IndexUtil;
-import org.apache.htrace.Span;
-import org.apache.htrace.Trace;
-import org.apache.htrace.TraceScope;
 
 import com.google.common.collect.Multimap;
 
@@ -157,11 +152,6 @@ public class Indexer extends BaseRegionObserver {
 
 // setup the actual index writer
 this.writer = new IndexWriter(env, serverName + "-index-writer");
-
-// setup the recovery writer that does retries on the failed edits
-TrackingParallelWriterIndexCommitter recoveryCommmiter =
-new TrackingParallelWriterIndexCommitter();
-
 try {
   // get the specified failure policy. We only ever override it in 
tests, but we need to do it
   // here
@@ -170,10 +160,9 @@ public class Indexer extends BaseRegionObserver {
 StoreFailuresInCachePolicy.class, IndexFailurePolicy.class);
   IndexFailurePolicy policy =
   
policyClass.getConstructor(PerRegionIndexWriteCache.class).newInstance(failedIndexEdits);
-  LOG.debug("Setting up recovery writter with committer: " + 
recoveryCommmiter.getClass()
-  + " and failure policy: " + policy.getClass());
+  LOG.debug("Setting up recovery writter with failure policy: " + 
policy.getClass());
   recoveryWriter =
-  new IndexWriter

[1/2] phoenix git commit: PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch

2016-07-12 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/master 919a89e3c -> e060a131b


PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/52d639fb
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/52d639fb
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/52d639fb

Branch: refs/heads/master
Commit: 52d639fb8b75d6c040a5e0fbbbac58d1e1ea4268
Parents: 919a89e
Author: Ankit Singhal 
Authored: Tue Jul 12 22:52:47 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 22:52:47 2016 +0530

--
 .../apache/phoenix/compile/FromCompiler.java|  8 ++--
 .../phoenix/iterate/BaseResultIterators.java|  5 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 47 +++-
 .../org/apache/phoenix/schema/PTableImpl.java   |  6 +--
 4 files changed, 38 insertions(+), 28 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/52d639fb/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
index 46e7d14..8e4d9aa 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
@@ -185,7 +185,7 @@ public class FromCompiler {
 if (htable != null) Closeables.closeQuietly(htable);
 }
 tableNode = NamedTableNode.create(null, baseTable, 
statement.getColumnDefs());
-return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1));
+return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1), false);
 }
 throw e;
 }
@@ -332,7 +332,7 @@ public class FromCompiler {
private final String alias;
 private final List schemas;
 
-   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes) 
throws SQLException  {
+   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes, 
boolean isNamespaceMapped) throws SQLException  {
super(connection, 0, false, udfParseNodes);
List families = 
Lists.newArrayListWithExpectedSize(table.getDynamicColumns().size());
for (ColumnDef def : table.getDynamicColumns()) {
@@ -345,8 +345,8 @@ public class FromCompiler {
 if (connection.getSchema() != null) {
 schema = schema != null ? schema : connection.getSchema();
 }
-PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
-scn == null ? HConstants.LATEST_TIMESTAMP : scn, families);
+   PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
+scn == null ? HConstants.LATEST_TIMESTAMP : scn, families, 
isNamespaceMapped);
theTable = this.addDynamicColumns(table.getDynamicColumns(), 
theTable);
alias = null;
tableRefs = ImmutableList.of(new TableRef(alias, theTable, 
timeStamp, !table.getDynamicColumns().isEmpty()));

http://git-wip-us.apache.org/repos/asf/phoenix/blob/52d639fb/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
index 6f053bf..4a797b8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
@@ -80,6 +80,7 @@ import org.apache.phoenix.schema.PColumnFamily;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.IndexType;
 import org.apache.phoenix.schema.PTable.ViewType;
+import org.apache.phoenix.schema.PTableType;
 import org.apache.phoenix.schema.StaleRegionBoundaryCacheException;
 import org.apache.phoenix.schema.TableRef;
 import org.apache.phoenix.schema.stats.GuidePostsInfo;
@@ -359,7 +360,9 @@ public abstract class BaseResultIterators extends 
ExplainTable implements Result
 if (null == currentSCN) {
   currentSCN = HConstants.LATEST_TIMESTAMP;
 }
-tableStats = useStats() ? 
context.getConnection().getQueryServices().getTableStats(physicalTableN

phoenix git commit: PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch

2016-07-12 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 04df7bca0 -> 45f0004e0


PHOENIX-3063 MutableIndexFailureIT is getting hanged in 4.x-HBase-0.98 branch


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/45f0004e
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/45f0004e
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/45f0004e

Branch: refs/heads/4.x-HBase-0.98
Commit: 45f0004e07ca7892dcb3dc757359671f2c141261
Parents: 04df7bc
Author: Ankit Singhal 
Authored: Tue Jul 12 18:20:44 2016 +0530
Committer: Ankit Singhal 
Committed: Tue Jul 12 18:20:44 2016 +0530

--
 .../apache/phoenix/compile/FromCompiler.java|  8 ++--
 .../phoenix/iterate/BaseResultIterators.java|  5 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 47 +++-
 .../org/apache/phoenix/schema/PTableImpl.java   |  6 +--
 4 files changed, 38 insertions(+), 28 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/45f0004e/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
index 46e7d14..8e4d9aa 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/FromCompiler.java
@@ -185,7 +185,7 @@ public class FromCompiler {
 if (htable != null) Closeables.closeQuietly(htable);
 }
 tableNode = NamedTableNode.create(null, baseTable, 
statement.getColumnDefs());
-return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1));
+return new SingleTableColumnResolver(connection, tableNode, 
e.getTimeStamp(), new HashMap(1), false);
 }
 throw e;
 }
@@ -332,7 +332,7 @@ public class FromCompiler {
private final String alias;
 private final List schemas;
 
-   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes) 
throws SQLException  {
+   public SingleTableColumnResolver(PhoenixConnection connection, 
NamedTableNode table, long timeStamp, Map udfParseNodes, 
boolean isNamespaceMapped) throws SQLException  {
super(connection, 0, false, udfParseNodes);
List families = 
Lists.newArrayListWithExpectedSize(table.getDynamicColumns().size());
for (ColumnDef def : table.getDynamicColumns()) {
@@ -345,8 +345,8 @@ public class FromCompiler {
 if (connection.getSchema() != null) {
 schema = schema != null ? schema : connection.getSchema();
 }
-PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
-scn == null ? HConstants.LATEST_TIMESTAMP : scn, families);
+   PTable theTable = new PTableImpl(connection.getTenantId(), schema, 
table.getName().getTableName(),
+scn == null ? HConstants.LATEST_TIMESTAMP : scn, families, 
isNamespaceMapped);
theTable = this.addDynamicColumns(table.getDynamicColumns(), 
theTable);
alias = null;
tableRefs = ImmutableList.of(new TableRef(alias, theTable, 
timeStamp, !table.getDynamicColumns().isEmpty()));

http://git-wip-us.apache.org/repos/asf/phoenix/blob/45f0004e/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
index 6f053bf..4a797b8 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/iterate/BaseResultIterators.java
@@ -80,6 +80,7 @@ import org.apache.phoenix.schema.PColumnFamily;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.IndexType;
 import org.apache.phoenix.schema.PTable.ViewType;
+import org.apache.phoenix.schema.PTableType;
 import org.apache.phoenix.schema.StaleRegionBoundaryCacheException;
 import org.apache.phoenix.schema.TableRef;
 import org.apache.phoenix.schema.stats.GuidePostsInfo;
@@ -359,7 +360,9 @@ public abstract class BaseResultIterators extends 
ExplainTable implements Result
 if (null == currentSCN) {
   currentSCN = HConstants.LATEST_TIMESTAMP;
 }
-tableStats = useStats() ? 
context.getConnection().getQueryServices().getTableStat