phoenix git commit: PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop
Repository: phoenix Updated Branches: refs/heads/master d058a41c5 - 1c58f442d PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/1c58f442 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/1c58f442 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/1c58f442 Branch: refs/heads/master Commit: 1c58f442dea6c19745a119f53e47e78ce9e2ef76 Parents: d058a41 Author: maryannxue wei@intel.com Authored: Thu Jan 29 11:42:24 2015 -0500 Committer: maryannxue wei@intel.com Committed: Thu Jan 29 11:42:24 2015 -0500 -- .../apache/phoenix/end2end/DerivedTableIT.java | 9 +++ .../org/apache/phoenix/end2end/HashJoinIT.java | 52 .../org/apache/phoenix/end2end/SubqueryIT.java | 10 ++-- .../end2end/SubqueryUsingSortMergeJoinIT.java | 10 ++-- phoenix-core/src/main/antlr3/PhoenixSQL.g | 6 +- .../apache/phoenix/compile/QueryCompiler.java | 12 ++-- .../apache/phoenix/execute/HashJoinPlan.java| 63 .../phoenix/expression/InListExpression.java| 9 +-- .../apache/phoenix/join/HashCacheClient.java| 58 +++--- .../apache/phoenix/optimize/QueryOptimizer.java | 2 +- .../java/org/apache/phoenix/parse/HintNode.java | 8 +-- 11 files changed, 120 insertions(+), 119 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/1c58f442/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java index 727293f..7a418bd 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java @@ -667,6 +667,15 @@ public class DerivedTableIT extends BaseClientManagedTimeIT { assertEquals(2,rs.getInt(1)); assertFalse(rs.next()); + +// count (subquery) +query = SELECT count(*) FROM (SELECT * FROM aTable WHERE (organization_id, entity_id) in (SELECT organization_id, entity_id FROM aTable WHERE a_byte != 8)) AS t; +statement = conn.prepareStatement(query); +rs = statement.executeQuery(); +assertTrue (rs.next()); +assertEquals(8,rs.getInt(1)); + +assertFalse(rs.next()); } finally { conn.close(); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/1c58f442/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index 9a95ea4..a699d48 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -229,7 +229,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ITEM_TABLE_DISPLAY_NAME + \n + SERVER FILTER BY FIRST KEY ONLY\n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (I2.item_id), +DYNAMIC SERVER FILTER BY item_id IN (I2.item_id), /* * testSelfJoin() * SELECT i1.name, i2.name FROM joinItemTable i1 @@ -241,7 +241,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { CLIENT MERGE SORT\n + PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ITEM_TABLE_DISPLAY_NAME + \n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (I2.supplier_id), +DYNAMIC SERVER FILTER BY item_id IN (I2.supplier_id), /* * testStarJoin() * SELECT order_id, c.name, i.name iname, quantity, o.date @@ -270,7 +270,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ORDER_TABLE_DISPLAY_NAME + \n + PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_CUSTOMER_TABLE_DISPLAY_NAME + \n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (O.item_id), +DYNAMIC SERVER FILTER BY item_id IN (O.item_id),
[3/3] phoenix git commit: PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop
PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/338747c9 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/338747c9 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/338747c9 Branch: refs/heads/4.0 Commit: 338747c9724c33b6a50132f0d7d5bbcf5802e194 Parents: 9ef28f6 Author: maryannxue wei@intel.com Authored: Thu Jan 29 11:54:48 2015 -0500 Committer: maryannxue wei@intel.com Committed: Thu Jan 29 11:54:48 2015 -0500 -- .../apache/phoenix/end2end/DerivedTableIT.java |9 + .../org/apache/phoenix/end2end/HashJoinIT.java | 52 +- .../org/apache/phoenix/end2end/SubqueryIT.java | 10 +- .../end2end/SubqueryUsingSortMergeJoinIT.java | 10 +- phoenix-core/src/main/antlr3/PhoenixSQL.g |6 +- .../apache/phoenix/compile/QueryCompiler.java | 12 +- .../coprocessor/MetaDataEndpointImpl.java.orig | 1793 -- .../apache/phoenix/execute/HashJoinPlan.java| 63 +- .../phoenix/expression/InListExpression.java|9 +- .../apache/phoenix/join/HashCacheClient.java| 58 +- .../apache/phoenix/optimize/QueryOptimizer.java |2 +- .../java/org/apache/phoenix/parse/HintNode.java |8 +- 12 files changed, 120 insertions(+), 1912 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/338747c9/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java index 430e5ab..562a98e 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java @@ -666,6 +666,15 @@ public class DerivedTableIT extends BaseClientManagedTimeIT { assertEquals(2,rs.getInt(1)); assertFalse(rs.next()); + +// count (subquery) +query = SELECT count(*) FROM (SELECT * FROM aTable WHERE (organization_id, entity_id) in (SELECT organization_id, entity_id FROM aTable WHERE a_byte != 8)) AS t; +statement = conn.prepareStatement(query); +rs = statement.executeQuery(); +assertTrue (rs.next()); +assertEquals(8,rs.getInt(1)); + +assertFalse(rs.next()); } finally { conn.close(); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/338747c9/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index 9a95ea4..a699d48 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -229,7 +229,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ITEM_TABLE_DISPLAY_NAME + \n + SERVER FILTER BY FIRST KEY ONLY\n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (I2.item_id), +DYNAMIC SERVER FILTER BY item_id IN (I2.item_id), /* * testSelfJoin() * SELECT i1.name, i2.name FROM joinItemTable i1 @@ -241,7 +241,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { CLIENT MERGE SORT\n + PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ITEM_TABLE_DISPLAY_NAME + \n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (I2.supplier_id), +DYNAMIC SERVER FILTER BY item_id IN (I2.supplier_id), /* * testStarJoin() * SELECT order_id, c.name, i.name iname, quantity, o.date @@ -270,7 +270,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ORDER_TABLE_DISPLAY_NAME + \n + PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_CUSTOMER_TABLE_DISPLAY_NAME + \n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (O.item_id), +DYNAMIC SERVER FILTER BY item_id IN (O.item_id), /* * testSubJoin()
[1/3] phoenix git commit: PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop
Repository: phoenix Updated Branches: refs/heads/4.0 9ef28f6f4 - 338747c97 http://git-wip-us.apache.org/repos/asf/phoenix/blob/338747c9/phoenix-core/src/main/java/org/apache/phoenix/execute/HashJoinPlan.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/execute/HashJoinPlan.java b/phoenix-core/src/main/java/org/apache/phoenix/execute/HashJoinPlan.java index db2a29d..aea075d 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/execute/HashJoinPlan.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/execute/HashJoinPlan.java @@ -31,7 +31,6 @@ import java.util.concurrent.atomic.AtomicLong; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.client.Scan; -import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; import org.apache.hadoop.hbase.io.ImmutableBytesWritable; import org.apache.phoenix.cache.ServerCacheClient.ServerCache; import org.apache.phoenix.compile.ColumnProjector; @@ -44,8 +43,6 @@ import org.apache.phoenix.compile.StatementContext; import org.apache.phoenix.compile.WhereCompiler; import org.apache.phoenix.exception.SQLExceptionCode; import org.apache.phoenix.exception.SQLExceptionInfo; -import org.apache.phoenix.expression.AndExpression; -import org.apache.phoenix.expression.ComparisonExpression; import org.apache.phoenix.expression.Determinism; import org.apache.phoenix.expression.Expression; import org.apache.phoenix.expression.InListExpression; @@ -58,7 +55,6 @@ import org.apache.phoenix.job.JobManager.JobCallable; import org.apache.phoenix.join.HashCacheClient; import org.apache.phoenix.join.HashJoinInfo; import org.apache.phoenix.parse.FilterableStatement; -import org.apache.phoenix.parse.HintNode.Hint; import org.apache.phoenix.parse.ParseNode; import org.apache.phoenix.parse.SQLParser; import org.apache.phoenix.parse.SelectStatement; @@ -82,8 +78,6 @@ public class HashJoinPlan extends DelegateQueryPlan { private final HashJoinInfo joinInfo; private final SubPlan[] subPlans; private final boolean recompileWhereClause; -private final boolean forceHashJoinRangeScan; -private final boolean forceHashJoinSkipScan; private ListSQLCloseable dependencies; private HashCacheClient hashClient; private int maxServerCacheTimeToLive; @@ -115,8 +109,6 @@ public class HashJoinPlan extends DelegateQueryPlan { this.joinInfo = joinInfo; this.subPlans = subPlans; this.recompileWhereClause = recompileWhereClause; -this.forceHashJoinRangeScan = plan.getStatement().getHint().hasHint(Hint.RANGE_SCAN_HASH_JOIN); -this.forceHashJoinSkipScan = plan.getStatement().getHint().hasHint(Hint.SKIP_SCAN_HASH_JOIN); } @Override @@ -200,39 +192,14 @@ public class HashJoinPlan extends DelegateQueryPlan { } private Expression createKeyRangeExpression(Expression lhsExpression, -Expression rhsExpression, ListImmutableBytesWritable rhsValues, -ImmutableBytesWritable ptr, boolean hasFilters) throws SQLException { +Expression rhsExpression, ListExpression rhsValues, +ImmutableBytesWritable ptr) throws SQLException { if (rhsValues.isEmpty()) -return LiteralExpression.newConstant(false, PBoolean.INSTANCE, Determinism.ALWAYS); +return LiteralExpression.newConstant(false, PBoolean.INSTANCE, Determinism.ALWAYS); -PDataType type = rhsExpression.getDataType(); -if (!useInClause(hasFilters)) { -ImmutableBytesWritable minValue = rhsValues.get(0); -ImmutableBytesWritable maxValue = rhsValues.get(0); -for (ImmutableBytesWritable value : rhsValues) { -if (value.compareTo(minValue) 0) { -minValue = value; -} -if (value.compareTo(maxValue) 0) { -maxValue = value; -} -} - -return AndExpression.create(Lists.newArrayList( -ComparisonExpression.create(CompareOp.GREATER_OR_EQUAL, Lists.newArrayList(lhsExpression, LiteralExpression.newConstant(type.toObject(minValue), type)), ptr), -ComparisonExpression.create(CompareOp.LESS_OR_EQUAL, Lists.newArrayList(lhsExpression, LiteralExpression.newConstant(type.toObject(maxValue), type)), ptr))); -} +rhsValues.add(0, lhsExpression); -ListExpression children = Lists.newArrayList(lhsExpression); -for (ImmutableBytesWritable value : rhsValues) { -children.add(LiteralExpression.newConstant(type.toObject(value), type)); -} - -return InListExpression.create(children, false, ptr, false); -} - -private boolean useInClause(boolean hasFilters) { -return this.forceHashJoinSkipScan ||
phoenix git commit: PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop
Repository: phoenix Updated Branches: refs/heads/3.0 a07318ccb - 4493ba381 PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/4493ba38 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/4493ba38 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/4493ba38 Branch: refs/heads/3.0 Commit: 4493ba381a4d76cf68870fa5991459f8c660f673 Parents: a07318c Author: maryannxue wei@intel.com Authored: Thu Jan 29 12:15:21 2015 -0500 Committer: maryannxue wei@intel.com Committed: Thu Jan 29 12:15:21 2015 -0500 -- .../apache/phoenix/end2end/DerivedTableIT.java | 9 +++ .../org/apache/phoenix/end2end/HashJoinIT.java | 36 ++-- .../org/apache/phoenix/end2end/SubqueryIT.java | 6 +- .../end2end/SubqueryUsingSortMergeJoinIT.java | 6 +- phoenix-core/src/main/antlr3/PhoenixSQL.g | 6 +- .../apache/phoenix/compile/QueryCompiler.java | 12 ++-- .../apache/phoenix/execute/HashJoinPlan.java| 61 .../phoenix/expression/InListExpression.java| 9 +-- .../apache/phoenix/join/HashCacheClient.java| 58 --- .../apache/phoenix/optimize/QueryOptimizer.java | 2 +- .../java/org/apache/phoenix/parse/HintNode.java | 8 +-- 11 files changed, 107 insertions(+), 106 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/4493ba38/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java index 430e5ab..562a98e 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java @@ -666,6 +666,15 @@ public class DerivedTableIT extends BaseClientManagedTimeIT { assertEquals(2,rs.getInt(1)); assertFalse(rs.next()); + +// count (subquery) +query = SELECT count(*) FROM (SELECT * FROM aTable WHERE (organization_id, entity_id) in (SELECT organization_id, entity_id FROM aTable WHERE a_byte != 8)) AS t; +statement = conn.prepareStatement(query); +rs = statement.executeQuery(); +assertTrue (rs.next()); +assertEquals(8,rs.getInt(1)); + +assertFalse(rs.next()); } finally { conn.close(); } http://git-wip-us.apache.org/repos/asf/phoenix/blob/4493ba38/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java index 4fc24d6..4bfb480 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/HashJoinIT.java @@ -228,7 +228,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ITEM_TABLE_DISPLAY_NAME + \n + SERVER FILTER BY FIRST KEY ONLY\n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (I2.item_id), +DYNAMIC SERVER FILTER BY item_id IN (I2.item_id), /* * testSelfJoin() * SELECT i1.name, i2.name FROM joinItemTable i1 @@ -240,7 +240,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { CLIENT MERGE SORT\n + PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ITEM_TABLE_DISPLAY_NAME + \n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (I2.supplier_id), +DYNAMIC SERVER FILTER BY item_id IN (I2.supplier_id), /* * testStarJoin() * SELECT order_id, c.name, i.name iname, quantity, o.date @@ -269,7 +269,7 @@ public class HashJoinIT extends BaseHBaseManagedTimeIT { CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_ORDER_TABLE_DISPLAY_NAME + \n + PARALLEL INNER-JOIN TABLE 0\n + CLIENT PARALLEL 1-WAY FULL SCAN OVER + JOIN_CUSTOMER_TABLE_DISPLAY_NAME + \n + -DYNAMIC SERVER FILTER BY item_id BETWEEN MIN/MAX OF (O.item_id), +DYNAMIC SERVER FILTER BY item_id IN (O.item_id), /*
Apache-Phoenix | 4.0 | Build Successful
4.0 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf/incubator-phoenix.git Compiled Artifacts https://builds.apache.org/job/Phoenix-4.0/lastSuccessfulBuild/artifact/ Test Report https://builds.apache.org/job/Phoenix-4.0/lastCompletedBuild/testReport/ Changes [maryannxue] PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
Build failed in Jenkins: Phoenix | Master #573
See https://builds.apache.org/job/Phoenix-master/573/changes Changes: [gabrielr] PHOENIX-1612 Avoid context classloader issue -- [...truncated 401 lines...] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.59 sec - in org.apache.phoenix.end2end.ExtendedQueryExecIT Running org.apache.phoenix.end2end.PointInTimeQueryIT Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.481 sec - in org.apache.phoenix.end2end.VariableLengthPKIT Running org.apache.phoenix.end2end.UpsertSelectIT Tests run: 126, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 71.241 sec - in org.apache.phoenix.end2end.QueryIT Running org.apache.phoenix.end2end.GroupByCaseIT Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.946 sec - in org.apache.phoenix.end2end.GroupByCaseIT Running org.apache.phoenix.end2end.ToCharFunctionIT Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.568 sec - in org.apache.phoenix.end2end.ToCharFunctionIT Running org.apache.phoenix.end2end.salted.SaltedTableIT Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.159 sec - in org.apache.phoenix.end2end.salted.SaltedTableIT Running org.apache.phoenix.end2end.FunkyNamesIT Tests run: 63, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 37.148 sec - in org.apache.phoenix.end2end.CaseStatementIT Running org.apache.phoenix.end2end.AggregateQueryIT Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.482 sec - in org.apache.phoenix.end2end.PointInTimeQueryIT Running org.apache.phoenix.end2end.ProductMetricsIT Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.821 sec - in org.apache.phoenix.end2end.FunkyNamesIT Running org.apache.phoenix.end2end.ScanQueryIT Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 34.263 sec - in org.apache.phoenix.end2end.RowValueConstructorIT Running org.apache.phoenix.end2end.ClientTimeArithmeticQueryIT Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 25.382 sec - in org.apache.phoenix.end2end.UpsertSelectIT Running org.apache.phoenix.end2end.GroupByIT Tests run: 61, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.414 sec - in org.apache.phoenix.end2end.ProductMetricsIT Tests run: 42, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 44.461 sec - in org.apache.phoenix.end2end.AggregateQueryIT Tests run: 119, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 60.573 sec - in org.apache.phoenix.end2end.ScanQueryIT Tests run: 91, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 56.637 sec - in org.apache.phoenix.end2end.GroupByIT Tests run: 210, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 99.892 sec - in org.apache.phoenix.end2end.ClientTimeArithmeticQueryIT Results : Tests run: 1226, Failures: 0, Errors: 0, Skipped: 0 [INFO] [INFO] --- maven-failsafe-plugin:2.18:integration-test (HBaseManagedTimeTests) @ phoenix-core --- [INFO] Failsafe report directory: https://builds.apache.org/job/Phoenix-master/ws/phoenix-core/target/failsafe-reports [INFO] parallel='none', perCoreThreadCount=true, threadCount=0, useUnlimitedThreads=false, threadCountSuites=0, threadCountClasses=0, threadCountMethods=0, parallelOptimized=true --- T E S T S --- Running org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT Running org.apache.phoenix.end2end.SubqueryUsingSortMergeJoinIT Running org.apache.phoenix.end2end.SortOrderFIT Running org.apache.phoenix.end2end.ReverseFunctionIT Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.374 sec - in org.apache.phoenix.end2end.ReverseFunctionIT Running org.apache.phoenix.end2end.UpsertSelectAutoCommitIT Running org.apache.phoenix.end2end.RegexpSplitFunctionIT Tests run: 30, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.118 sec - in org.apache.phoenix.end2end.RoundFloorCeilFunctionsEnd2EndIT Running org.apache.phoenix.end2end.EncodeFunctionIT Tests run: 30, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.129 sec - in org.apache.phoenix.end2end.SortOrderFIT Running org.apache.phoenix.end2end.NthValueFunctionIT Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.513 sec - in org.apache.phoenix.end2end.RegexpSplitFunctionIT Running org.apache.phoenix.end2end.index.SaltedIndexIT Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.281 sec - in org.apache.phoenix.end2end.NthValueFunctionIT Running org.apache.phoenix.end2end.index.DropViewIT Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.909 sec - in org.apache.phoenix.end2end.EncodeFunctionIT Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.256 sec - in org.apache.phoenix.end2end.UpsertSelectAutoCommitIT Running org.apache.phoenix.end2end.index.ImmutableIndexIT Running org.apache.phoenix.end2end.index.GlobalMutableIndexIT Tests run: 1, Failures: 0, Errors: 0,
Jenkins build is back to normal : Phoenix | Master #574
See https://builds.apache.org/job/Phoenix-master/574/changes
Apache-Phoenix | 3.0 | Hadoop1 | Build Successful
3.0 branch build status Successful Source repository https://git-wip-us.apache.org/repos/asf/phoenix.git Last Successful Compiled Artifacts https://builds.apache.org/job/Phoenix-3.0-hadoop1/lastSuccessfulBuild/artifact/ Last Complete Test Report https://builds.apache.org/job/Phoenix-3.0-hadoop1/lastCompletedBuild/testReport/ Changes [maryannxue] PHOENIX-1610 Incorrect subquery results caused by unpaired contextStack push/pop Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout
phoenix git commit: PHOENIX-1612 Avoid context classloader issue
Repository: phoenix Updated Branches: refs/heads/master b12ddfa3f - d058a41c5 PHOENIX-1612 Avoid context classloader issue Don't create a static HColumnDescriptor to avoid creating an HBaseConfiguration from a static context. Making this change makes it possible to run Phoenix via an external jar file in tools like DBVisualier (instead of having to put Phoenix directly in the application classpath). Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/d058a41c Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/d058a41c Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/d058a41c Branch: refs/heads/master Commit: d058a41c52c6a68c1581eff520c1f9e12486b89c Parents: b12ddfa Author: Gabriel Reid gabri...@ngdata.com Authored: Wed Jan 28 20:30:33 2015 +0100 Committer: Gabriel Reid gabri...@ngdata.com Committed: Thu Jan 29 11:04:58 2015 +0100 -- .../org/apache/phoenix/query/ConnectionQueryServicesImpl.java| 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/d058a41c/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java -- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java index d545b2b..97efc43 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java @@ -200,8 +200,6 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement private volatile ConcurrentMapSequenceKey,Sequence sequenceMap = Maps.newConcurrentMap(); private KeyValueBuilder kvBuilder; -private static final HColumnDescriptor defaultColDescriptor = new HColumnDescriptor(QueryConstants.DEFAULT_COLUMN_FAMILY_BYTES); - private PMetaData newEmptyMetaData() { long maxSizeBytes = props.getLong(QueryServices.MAX_CLIENT_METADATA_CACHE_SIZE_ATTRIB, QueryServicesOptions.DEFAULT_MAX_CLIENT_METADATA_CACHE_SIZE); @@ -1673,7 +1671,7 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement } private boolean isHColumnProperty(String propName) { -return defaultColDescriptor.getValue(propName) != null; +return HColumnDescriptor.getDefaultValues().containsKey(propName); } private boolean isHTableProperty(String propName) {