Build failed in Jenkins: Phoenix-4.x-HBase-1.x #7

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[thomas] PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work 
correctly

--
[...truncated 129547 lines...]
  Run 1: AlterTableIT.testAlterStoreNulls:1860 » PhoenixIO 
org.apache.phoenix.exception...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties:1964 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisableWAL(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDisableWAL:728 » PhoenixIO 
org.apache.hadoop.hbase.DoNotRetry...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable:697 
» PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnFromSaltedTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnFromSaltedTable:546 » PhoenixIO 
org.apache.hadoop.h...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnsWithImutability(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnsWithImutability:823 » PhoenixIO 
org.apache.hadoop
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropCoveredColumn(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropCoveredColumn:319 » PhoenixIO 
org.apache.hadoop.hbase.DoN...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testDropVarCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropVarCols:673 » PhoenixIO 
org.apache.hadoop.hbase.DoNotRetr...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:1302 » PhoenixIO 
org.apac...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed:1213 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols:1711
 » PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.delete

Build failed in Jenkins: Phoenix | Master #635

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[thomas] PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work 
correctly

--
[...truncated 129141 lines...]

org.apache.phoenix.end2end.AlterTableIT.testDropColumnsWithImutability(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnsWithImutability:823 » PhoenixIO 
org.apache.hadoop
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropCoveredColumn(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropCoveredColumn:319 » PhoenixIO 
org.apache.hadoop.hbase.DoN...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testDropVarCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropVarCols:673 » PhoenixIO 
org.apache.hadoop.hbase.DoNotRetr...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:1302 » PhoenixIO 
org.apac...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed:1213 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols:1711
 » PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHTableHColumnAndPhoenixTableProperties(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHTableHColumnAndPhoenixTableProperties:1063 » 
PhoenixIO or...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetPropertyAndAddColumnForDifferentColumnFamilies(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetPropertyAndAddColumnForDifferentColumnFamilies:1427 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testSetPropertyAndAddColumnForNewAndExistingColumnFamily(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetPropertyAndAddColumnForNewAndExistingColumnFamily:1351 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testSetPropertyAn

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

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[thomas] PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work 
correctly

--
[...truncated 506 lines...]
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.262 sec - in 
org.apache.phoenix.end2end.UpsertSelectAutoCommitIT
Running org.apache.phoenix.end2end.ModulusExpressionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.679 sec - in 
org.apache.phoenix.end2end.ServerExceptionIT
Running org.apache.phoenix.end2end.SubqueryUsingSortMergeJoinIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.102 sec - in 
org.apache.phoenix.end2end.ModulusExpressionIT
Running org.apache.phoenix.end2end.BinaryRowKeyIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.066 sec - in 
org.apache.phoenix.end2end.BinaryRowKeyIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 58, Failures: 8, Errors: 0, Skipped: 0, Time elapsed: 135.71 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.IndexExpressionIT
testGroupByCountMutableIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.253 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
B.INT_COL2)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 
B.INT_COL2)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestGroupByCount(IndexExpressionIT.java:484)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testGroupByCountMutableIndex(IndexExpressionIT.java:456)

testSelectDistinctImmutableIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.251 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testSelectDistinctImmutableIndex(IndexExpressionIT.java:499)

testSelectDistinctImmutableIndexLocal(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.252 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testSelectDistinctImmutableIndexLocal(IndexExpressionIT.java:504)

testSelectDistinctMutableIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 5.698 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testSelectDistinctMutableIndex(IndexExpressionIT.java:509)

testGroupByCountImmutableLocalIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.27 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
B.INT_COL2)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 
B.INT_COL2)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestGroupByCount(IndexExpressionIT.java:484)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testGroupByCountImmutableLocalIndex(IndexExpressionIT.java:451)

testSelectDistinctMutableLocalIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.262 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.Ind

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

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[thomas] PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work 
correctly

--
[...truncated 509 lines...]
Tests run: 30, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.811 sec - in 
org.apache.phoenix.end2end.SortOrderFIT
Running org.apache.phoenix.end2end.HashJoinIT
Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 55.591 sec - 
in org.apache.phoenix.end2end.index.GlobalMutableIndexIT
Running org.apache.phoenix.end2end.HashJoinLocalIndexIT
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 123.167 sec - 
in org.apache.phoenix.end2end.index.LocalIndexIT
Running org.apache.phoenix.end2end.ModulusExpressionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.512 sec - in 
org.apache.phoenix.end2end.HashJoinLocalIndexIT
Running org.apache.phoenix.end2end.StoreNullsIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.157 sec - in 
org.apache.phoenix.end2end.ModulusExpressionIT
Running org.apache.phoenix.end2end.EvaluationOfORIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.758 sec - in 
org.apache.phoenix.end2end.EvaluationOfORIT
Running org.apache.phoenix.end2end.ExecuteStatementsIT
Tests run: 58, Failures: 8, Errors: 0, Skipped: 0, Time elapsed: 129.693 sec 
<<< FAILURE! - in org.apache.phoenix.end2end.index.IndexExpressionIT
testGroupByCountMutableIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.228 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
B.INT_COL2)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 
B.INT_COL2)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestGroupByCount(IndexExpressionIT.java:484)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testGroupByCountMutableIndex(IndexExpressionIT.java:456)

testSelectDistinctImmutableIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.234 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testSelectDistinctImmutableIndex(IndexExpressionIT.java:499)

testSelectDistinctImmutableIndexLocal(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.221 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testSelectDistinctImmutableIndexLocal(IndexExpressionIT.java:504)

testSelectDistinctMutableIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 5.684 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 1)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestSelectDistinct(IndexExpressionIT.java:535)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testSelectDistinctMutableIndex(IndexExpressionIT.java:509)

testGroupByCountImmutableLocalIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.239 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
B.INT_COL2)])]
CLIENT MERGE SORT> but was:<... ROWS BY [TO_BIGINT(["(A.INT_COL1 + 
B.INT_COL2)"])]
CLIENT MERGE SORT>
at org.junit.Assert.assertEquals(Assert.java:115)
at org.junit.Assert.assertEquals(Assert.java:144)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.helpTestGroupByCount(IndexExpressionIT.java:484)
at 
org.apache.phoenix.end2end.index.IndexExpressionIT.testGroupByCountImmutableLocalIndex(IndexExpressionIT.java:451)

testSelectDistinctMutableLocalIndex(org.apache.phoenix.end2end.index.IndexExpressionIT)
  Time elapsed: 0.258 sec  <<< FAILURE!
org.junit.ComparisonFailure: expected:<... ROWS BY [TO_BIGINT([(A.INT_COL1 + 
1)])]
CLI

[1/2] phoenix git commit: PHOENIX-1115 Provide a SQL command to turn tracing on/off(Rajeshbabu)

2015-03-24 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.3 147e27eee -> f977ac6f3


PHOENIX-1115 Provide a SQL command to turn tracing on/off(Rajeshbabu)


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

Branch: refs/heads/4.3
Commit: 30ddd77054d22dc99aa0798ca42df9a329f689c3
Parents: 147e27e
Author: Rajeshbabu Chintaguntla 
Authored: Sat Feb 28 05:49:53 2015 +0530
Committer: James Taylor 
Committed: Tue Mar 24 16:03:41 2015 -0700

--
 .../phoenix/trace/PhoenixTracingEndToEndIT.java |  32 ++-
 phoenix-core/src/main/antlr3/PhoenixSQL.g   |  10 +
 .../apache/phoenix/compile/TraceQueryPlan.java  | 220 +++
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  17 ++
 .../apache/phoenix/jdbc/PhoenixStatement.java   |  24 +-
 .../apache/phoenix/parse/ParseNodeFactory.java  |   4 +
 .../apache/phoenix/parse/TraceStatement.java|  43 
 .../org/apache/phoenix/trace/util/Tracing.java  |  10 +
 8 files changed, 358 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/30ddd770/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
index 201de38..53d22c5 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
@@ -19,12 +19,15 @@ package org.apache.phoenix.trace;
 
 import static org.apache.phoenix.util.PhoenixRuntime.TENANT_ID_ATTRIB;
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 
 import java.sql.Connection;
+import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.util.Collection;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
@@ -33,6 +36,7 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.metrics2.MetricsSource;
 import org.apache.phoenix.coprocessor.BaseScannerRegionObserver;
+import org.apache.phoenix.jdbc.PhoenixConnection;
 import org.apache.phoenix.metrics.Metrics;
 import org.apache.phoenix.query.QueryServicesOptions;
 import org.apache.phoenix.trace.TraceReader.SpanInfo;
@@ -391,7 +395,33 @@ public class PhoenixTracingEndToEndIT extends 
BaseTracingTestIT {
 assertAnnotationPresent(TENANT_ID_ATTRIB, tenantId, conn);
 // CurrentSCN is also added as an annotation. Not tested here because 
it screws up test setup.
 }
-
+
+@Test
+public void testTraceOnOrOff() throws Exception {
+Connection conn1 = DriverManager.getConnection(getUrl());
+try{
+Statement statement = conn1.createStatement();
+ResultSet  rs = statement.executeQuery("TRACE ON");
+assertTrue(rs.next());
+long traceId = ((PhoenixConnection) 
conn1).getTraceScope().getSpan()
+.getTraceId();
+assertEquals(rs.getLong(1), traceId);
+assertEquals(rs.getLong("trace_id"), traceId);
+assertFalse(rs.next());
+
+rs = statement.executeQuery("TRACE OFF");
+assertTrue(rs.next());
+assertEquals(rs.getLong(1), traceId);
+assertEquals(rs.getLong("trace_id"), traceId);
+assertFalse(rs.next());
+
+rs = statement.executeQuery("TRACE OFF");
+assertFalse(rs.next());
+   } finally {
+conn1.close();
+}
+}
+
 private void assertAnnotationPresent(final String annotationKey, final 
String annotationValue, Connection conn) throws Exception {
 boolean tracingComplete = checkStoredTraces(conn, new TraceChecker(){
 @Override

http://git-wip-us.apache.org/repos/asf/phoenix/blob/30ddd770/phoenix-core/src/main/antlr3/PhoenixSQL.g
--
diff --git a/phoenix-core/src/main/antlr3/PhoenixSQL.g 
b/phoenix-core/src/main/antlr3/PhoenixSQL.g
index f536c49..a007308 100644
--- a/phoenix-core/src/main/antlr3/PhoenixSQL.g
+++ b/phoenix-core/src/main/antlr3/PhoenixSQL.g
@@ -33,6 +33,7 @@ tokens
 AS='as';
 OUTER='outer';
 ON='on';
+OFF='off';
 IN='in';
 GROUP='group';
 HAVING='having';
@@ -107,6 +108,7 @@ tokens
 UPDATE='update';
 STATI

[2/2] phoenix git commit: PHOENIX-1691 Allow settting sampling rate while enabling tracing.(Rajeshbabu)

2015-03-24 Thread jamestaylor
PHOENIX-1691 Allow settting sampling rate while enabling tracing.(Rajeshbabu)

Conflicts:

phoenix-core/src/main/antlr3/PhoenixSQL.g


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

Branch: refs/heads/4.3
Commit: f977ac6f351716f4c4143fdef080e0beb938b1ba
Parents: 30ddd77
Author: Rajeshbabu Chintaguntla 
Authored: Wed Mar 18 10:20:22 2015 +0530
Committer: James Taylor 
Committed: Tue Mar 24 16:16:19 2015 -0700

--
 .../phoenix/trace/PhoenixTracingEndToEndIT.java | 39 +---
 phoenix-core/src/main/antlr3/PhoenixSQL.g   |  9 -
 .../apache/phoenix/compile/TraceQueryPlan.java  | 33 -
 .../apache/phoenix/jdbc/PhoenixStatement.java   |  8 ++--
 .../apache/phoenix/parse/ParseNodeFactory.java  |  4 +-
 .../apache/phoenix/parse/TraceStatement.java| 12 --
 6 files changed, 79 insertions(+), 26 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/f977ac6f/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
index 53d22c5..05d9e41 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
@@ -46,6 +46,7 @@ import org.cloudera.htrace.Span;
 import org.cloudera.htrace.SpanReceiver;
 import org.cloudera.htrace.Trace;
 import org.cloudera.htrace.TraceScope;
+import org.cloudera.htrace.impl.ProbabilitySampler;
 import org.junit.After;
 import org.junit.BeforeClass;
 import org.junit.Test;
@@ -403,18 +404,44 @@ public class PhoenixTracingEndToEndIT extends 
BaseTracingTestIT {
 Statement statement = conn1.createStatement();
 ResultSet  rs = statement.executeQuery("TRACE ON");
 assertTrue(rs.next());
-long traceId = ((PhoenixConnection) 
conn1).getTraceScope().getSpan()
-.getTraceId();
-assertEquals(rs.getLong(1), traceId);
-assertEquals(rs.getLong("trace_id"), traceId);
+PhoenixConnection pconn= (PhoenixConnection) conn1;
+long traceId = pconn.getTraceScope().getSpan().getTraceId();
+assertEquals(traceId, rs.getLong(1));
+assertEquals(traceId, rs.getLong("trace_id"));
 assertFalse(rs.next());
+assertEquals(Sampler.ALWAYS, pconn.getSampler());
 
 rs = statement.executeQuery("TRACE OFF");
 assertTrue(rs.next());
-assertEquals(rs.getLong(1), traceId);
-assertEquals(rs.getLong("trace_id"), traceId);
+assertEquals(traceId, rs.getLong(1));
+assertEquals(traceId, rs.getLong("trace_id"));
+assertFalse(rs.next());
+assertEquals(Sampler.NEVER, pconn.getSampler());
+
+rs = statement.executeQuery("TRACE OFF");
 assertFalse(rs.next());
 
+rs = statement.executeQuery("TRACE ON  WITH SAMPLING 0.5");
+rs.next();
+assertTrue(((PhoenixConnection) conn1).getSampler() instanceof 
ProbabilitySampler);
+
+rs = statement.executeQuery("TRACE ON  WITH SAMPLING 1.0");
+assertTrue(rs.next());
+traceId = pconn.getTraceScope().getSpan()
+.getTraceId();
+assertEquals(traceId, rs.getLong(1));
+assertEquals(traceId, rs.getLong("trace_id"));
+assertFalse(rs.next());
+assertEquals(Sampler.ALWAYS, pconn.getSampler());
+
+rs = statement.executeQuery("TRACE ON  WITH SAMPLING 0.5");
+rs.next();
+assertTrue(((PhoenixConnection) conn1).getSampler() instanceof 
ProbabilitySampler);
+
+rs = statement.executeQuery("TRACE ON WITH SAMPLING 0.0");
+rs.next();
+assertEquals(Sampler.NEVER, pconn.getSampler());
+
 rs = statement.executeQuery("TRACE OFF");
 assertFalse(rs.next());
} finally {

http://git-wip-us.apache.org/repos/asf/phoenix/blob/f977ac6f/phoenix-core/src/main/antlr3/PhoenixSQL.g
--
diff --git a/phoenix-core/src/main/antlr3/PhoenixSQL.g 
b/phoenix-core/src/main/antlr3/PhoenixSQL.g
index a007308..b72578c 100644
--- a/phoenix-core/src/main/antlr3/PhoenixSQL.g
+++ b/phoenix-core/src/main/antlr3/PhoenixSQL.g
@@ -109,6 +109,7 @@ tokens
 STATISTICS='statistics';
 COLUMNS='colu

Build failed in Jenkins: Phoenix-4.x-HBase-1.x #6

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[thomas] PHOENIX-1744 Allow Integer, UnsignedInt and UnsignedLong to be Cast to 
TIMESTAMP (Dave Hacker)

--
[...truncated 127169 lines...]
  Run 1: AlterTableIT.testAlterStoreNulls:1860 ? PhoenixIO 
org.apache.phoenix.exception...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties:1964 ? 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisableWAL(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDisableWAL:728 ? PhoenixIO 
org.apache.hadoop.hbase.DoNotRetry...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable:697 
? PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnFromSaltedTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnFromSaltedTable:546 ? PhoenixIO 
org.apache.hadoop.h...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnsWithImutability(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnsWithImutability:823 ? PhoenixIO 
org.apache.hadoop
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropCoveredColumn(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropCoveredColumn:319 ? PhoenixIO 
org.apache.hadoop.hbase.DoN...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testDropVarCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropVarCols:673 ? PhoenixIO 
org.apache.hadoop.hbase.DoNotRetr...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:1302 ? PhoenixIO 
org.apac...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed:1213 ? 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols:1711
 ? PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTable

phoenix git commit: PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly

2015-03-24 Thread tdsilva
Repository: phoenix
Updated Branches:
  refs/heads/master ab9c9283e -> a94a6f419


PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly


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

Branch: refs/heads/master
Commit: a94a6f4195af2867379803f19c90045eb3943c2d
Parents: ab9c928
Author: Thomas 
Authored: Thu Mar 19 13:57:27 2015 -0700
Committer: Thomas 
Committed: Tue Mar 24 15:58:52 2015 -0700

--
 .../end2end/index/IndexExpressionIT.java| 161 ++-
 .../phoenix/compile/PostIndexDDLCompiler.java   |   4 +-
 .../parse/IndexExpressionParseNodeRewriter.java |  30 +---
 .../apache/phoenix/schema/MetaDataClient.java   |   4 +-
 .../org/apache/phoenix/util/StringUtil.java |   5 +
 .../phoenix/compile/QueryCompilerTest.java  |  22 ++-
 6 files changed, 153 insertions(+), 73 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/a94a6f41/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
index 1e3733b..0203e35 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
@@ -1202,54 +1202,60 @@ public class IndexExpressionIT extends 
BaseHBaseManagedTimeIT {
 
 @Test
 public void testViewUsesTableIndex() throws Exception {
-ResultSet rs;
 Connection conn = DriverManager.getConnection(getUrl());
-String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER NOT 
NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY KEY 
(k1, k2))";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, s3, s1)");
-conn.createStatement().execute("CREATE INDEX i2 ON t(k2, s2||'_'||s3, 
s1, s4)");
-
-ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("UPSERT INTO t 
VALUES(1,1,'foo','abc','cab')");
-conn.createStatement().execute("UPSERT INTO t 
VALUES(2,2,'bar','xyz','zyx')");
-conn.commit();
-
-rs = conn.createStatement().executeQuery("SELECT count(*) FROM v");
-assertTrue(rs.next());
-assertEquals(1, rs.getLong(1));
-assertFalse(rs.next());
-
-//i2 should be used since it contains s3||'_'||s4 i
-String query = "SELECT s2||'_'||s3 FROM v WHERE k2=1 AND 
(s2||'_'||s3)='abc_cab'";
-rs = conn.createStatement(  ).executeQuery("EXPLAIN " + query);
-String queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I2 
[1,'abc_cab','foo']\n" + 
-"SERVER FILTER BY FIRST KEY ONLY", queryPlan);
-rs = conn.createStatement().executeQuery(query);
-assertTrue(rs.next());
-assertEquals("abc_cab", rs.getString(1));
-assertFalse(rs.next());
-
-conn.createStatement().execute("ALTER VIEW v DROP COLUMN s4");
-//i2 cannot be used since s4 has been dropped from the view, so i1 
will be used 
-rs = conn.createStatement().executeQuery("EXPLAIN " + query);
-queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I1 [1]\n" + 
-"SERVER FILTER BY FIRST KEY ONLY AND ((\"S2\" || '_' || 
\"S3\") = 'abc_cab' AND \"S1\" = 'foo')", queryPlan);
-rs = conn.createStatement().executeQuery(query);
-assertTrue(rs.next());
-assertEquals("abc_cab", rs.getString(1));
-assertFalse(rs.next());
+try 
+{
+   ResultSet rs;
+   String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER 
NOT NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY 
KEY (k1, k2))";
+   conn.createStatement().execute(ddl);
+   conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, 
s3, s1)");
+   conn.createStatement().execute("CREATE INDEX i2 ON t(k2, 
s2||'_'||s3, s1, s4)");
+   
+   ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
+   conn.createStatement().execute(ddl);
+   conn.createStatement().execute("UPSERT INTO t 
VALUES(1,1,'foo','

phoenix git commit: PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly

2015-03-24 Thread tdsilva
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.x 250474deb -> a8b27e3f0


PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly


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

Branch: refs/heads/4.x-HBase-1.x
Commit: a8b27e3f010d15d3f3b519c38fbb052ebb4a6cdb
Parents: 250474d
Author: Thomas 
Authored: Thu Mar 19 13:57:27 2015 -0700
Committer: Thomas 
Committed: Tue Mar 24 15:56:25 2015 -0700

--
 .../end2end/index/IndexExpressionIT.java| 161 ++-
 .../phoenix/compile/PostIndexDDLCompiler.java   |   4 +-
 .../parse/IndexExpressionParseNodeRewriter.java |  30 +---
 .../apache/phoenix/schema/MetaDataClient.java   |   4 +-
 .../org/apache/phoenix/util/StringUtil.java |   5 +
 .../phoenix/compile/QueryCompilerTest.java  |  22 ++-
 6 files changed, 153 insertions(+), 73 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/a8b27e3f/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
index 1e3733b..0203e35 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
@@ -1202,54 +1202,60 @@ public class IndexExpressionIT extends 
BaseHBaseManagedTimeIT {
 
 @Test
 public void testViewUsesTableIndex() throws Exception {
-ResultSet rs;
 Connection conn = DriverManager.getConnection(getUrl());
-String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER NOT 
NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY KEY 
(k1, k2))";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, s3, s1)");
-conn.createStatement().execute("CREATE INDEX i2 ON t(k2, s2||'_'||s3, 
s1, s4)");
-
-ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("UPSERT INTO t 
VALUES(1,1,'foo','abc','cab')");
-conn.createStatement().execute("UPSERT INTO t 
VALUES(2,2,'bar','xyz','zyx')");
-conn.commit();
-
-rs = conn.createStatement().executeQuery("SELECT count(*) FROM v");
-assertTrue(rs.next());
-assertEquals(1, rs.getLong(1));
-assertFalse(rs.next());
-
-//i2 should be used since it contains s3||'_'||s4 i
-String query = "SELECT s2||'_'||s3 FROM v WHERE k2=1 AND 
(s2||'_'||s3)='abc_cab'";
-rs = conn.createStatement(  ).executeQuery("EXPLAIN " + query);
-String queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I2 
[1,'abc_cab','foo']\n" + 
-"SERVER FILTER BY FIRST KEY ONLY", queryPlan);
-rs = conn.createStatement().executeQuery(query);
-assertTrue(rs.next());
-assertEquals("abc_cab", rs.getString(1));
-assertFalse(rs.next());
-
-conn.createStatement().execute("ALTER VIEW v DROP COLUMN s4");
-//i2 cannot be used since s4 has been dropped from the view, so i1 
will be used 
-rs = conn.createStatement().executeQuery("EXPLAIN " + query);
-queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I1 [1]\n" + 
-"SERVER FILTER BY FIRST KEY ONLY AND ((\"S2\" || '_' || 
\"S3\") = 'abc_cab' AND \"S1\" = 'foo')", queryPlan);
-rs = conn.createStatement().executeQuery(query);
-assertTrue(rs.next());
-assertEquals("abc_cab", rs.getString(1));
-assertFalse(rs.next());
+try 
+{
+   ResultSet rs;
+   String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER 
NOT NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY 
KEY (k1, k2))";
+   conn.createStatement().execute(ddl);
+   conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, 
s3, s1)");
+   conn.createStatement().execute("CREATE INDEX i2 ON t(k2, 
s2||'_'||s3, s1, s4)");
+   
+   ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
+   conn.createStatement().execute(ddl);
+   conn.createStatement().execute("UPSERT INTO t 
VALU

phoenix git commit: PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly

2015-03-24 Thread tdsilva
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 af0d65a0a -> c992c8694


PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly


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

Branch: refs/heads/4.x-HBase-0.98
Commit: c992c86941798f960948df12ae40ee2d4a0ae820
Parents: af0d65a
Author: Thomas 
Authored: Thu Mar 19 13:57:27 2015 -0700
Committer: Thomas 
Committed: Tue Mar 24 15:49:49 2015 -0700

--
 .../end2end/index/IndexExpressionIT.java| 161 ++-
 .../phoenix/compile/PostIndexDDLCompiler.java   |   4 +-
 .../parse/IndexExpressionParseNodeRewriter.java |  30 +---
 .../apache/phoenix/schema/MetaDataClient.java   |   4 +-
 .../org/apache/phoenix/util/StringUtil.java |   5 +
 .../phoenix/compile/QueryCompilerTest.java  |  22 ++-
 6 files changed, 153 insertions(+), 73 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c992c869/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
index 1e3733b..0203e35 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
@@ -1202,54 +1202,60 @@ public class IndexExpressionIT extends 
BaseHBaseManagedTimeIT {
 
 @Test
 public void testViewUsesTableIndex() throws Exception {
-ResultSet rs;
 Connection conn = DriverManager.getConnection(getUrl());
-String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER NOT 
NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY KEY 
(k1, k2))";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, s3, s1)");
-conn.createStatement().execute("CREATE INDEX i2 ON t(k2, s2||'_'||s3, 
s1, s4)");
-
-ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("UPSERT INTO t 
VALUES(1,1,'foo','abc','cab')");
-conn.createStatement().execute("UPSERT INTO t 
VALUES(2,2,'bar','xyz','zyx')");
-conn.commit();
-
-rs = conn.createStatement().executeQuery("SELECT count(*) FROM v");
-assertTrue(rs.next());
-assertEquals(1, rs.getLong(1));
-assertFalse(rs.next());
-
-//i2 should be used since it contains s3||'_'||s4 i
-String query = "SELECT s2||'_'||s3 FROM v WHERE k2=1 AND 
(s2||'_'||s3)='abc_cab'";
-rs = conn.createStatement(  ).executeQuery("EXPLAIN " + query);
-String queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I2 
[1,'abc_cab','foo']\n" + 
-"SERVER FILTER BY FIRST KEY ONLY", queryPlan);
-rs = conn.createStatement().executeQuery(query);
-assertTrue(rs.next());
-assertEquals("abc_cab", rs.getString(1));
-assertFalse(rs.next());
-
-conn.createStatement().execute("ALTER VIEW v DROP COLUMN s4");
-//i2 cannot be used since s4 has been dropped from the view, so i1 
will be used 
-rs = conn.createStatement().executeQuery("EXPLAIN " + query);
-queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I1 [1]\n" + 
-"SERVER FILTER BY FIRST KEY ONLY AND ((\"S2\" || '_' || 
\"S3\") = 'abc_cab' AND \"S1\" = 'foo')", queryPlan);
-rs = conn.createStatement().executeQuery(query);
-assertTrue(rs.next());
-assertEquals("abc_cab", rs.getString(1));
-assertFalse(rs.next());
+try 
+{
+   ResultSet rs;
+   String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER 
NOT NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY 
KEY (k1, k2))";
+   conn.createStatement().execute(ddl);
+   conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, 
s3, s1)");
+   conn.createStatement().execute("CREATE INDEX i2 ON t(k2, 
s2||'_'||s3, s1, s4)");
+   
+   ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
+   conn.createStatement().execute(ddl);
+   conn.createStatement().execute("UPSERT INTO t 
VA

phoenix git commit: PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly

2015-03-24 Thread tdsilva
Repository: phoenix
Updated Branches:
  refs/heads/4.3 362e37264 -> 147e27eee


PHOENIX-1684 Functional Index using REGEXP_SUBSTR doesn't work correctly


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

Branch: refs/heads/4.3
Commit: 147e27eee0f0cc4f1105db3af6feaed3dfcd2455
Parents: 362e372
Author: Thomas 
Authored: Thu Mar 19 13:57:27 2015 -0700
Committer: Thomas 
Committed: Tue Mar 24 13:50:09 2015 -0700

--
 .../end2end/index/IndexExpressionIT.java| 165 ++-
 .../phoenix/compile/PostIndexDDLCompiler.java   |   5 +-
 .../parse/IndexExpressionParseNodeRewriter.java |  30 +---
 .../apache/phoenix/schema/MetaDataClient.java   |   4 +-
 .../org/apache/phoenix/util/StringUtil.java |   5 +
 .../phoenix/compile/QueryCompilerTest.java  |  22 ++-
 6 files changed, 156 insertions(+), 75 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/147e27ee/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
index 1e3733b..1a5fbcc 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexExpressionIT.java
@@ -480,7 +480,7 @@ public class IndexExpressionIT extends 
BaseHBaseManagedTimeIT {
 String expectedPlan = "CLIENT PARALLEL 1-WAY "
 + (localIndex ? "RANGE SCAN OVER _LOCAL_IDX_" + 
fullDataTableName + " [-32768]"
 : "FULL SCAN OVER INDEX_TEST.IDX")
-+ "\nSERVER FILTER BY FIRST KEY ONLY\nSERVER 
AGGREGATE INTO ORDERED DISTINCT ROWS BY [TO_BIGINT((A.INT_COL1 + 
B.INT_COL2))]\nCLIENT MERGE SORT";
++ "\nSERVER FILTER BY FIRST KEY ONLY\nSERVER 
AGGREGATE INTO ORDERED DISTINCT ROWS BY [TO_BIGINT(\"(A.INT_COL1 + 
B.INT_COL2)\")]\nCLIENT MERGE SORT";
 assertEquals(expectedPlan, QueryUtil.getExplainPlan(rs));
 rs = conn.createStatement().executeQuery(groupBySql);
 assertTrue(rs.next());
@@ -531,7 +531,7 @@ public class IndexExpressionIT extends 
BaseHBaseManagedTimeIT {
 String expectedPlan = "CLIENT PARALLEL 1-WAY RANGE SCAN OVER "
 + (localIndex ? "_LOCAL_IDX_" + fullDataTableName + " 
[-32768,0] - [-32768,*]"
 : "INDEX_TEST.IDX [0] - [*]")
-+ "\nSERVER FILTER BY FIRST KEY ONLY\nSERVER 
AGGREGATE INTO ORDERED DISTINCT ROWS BY [TO_BIGINT((A.INT_COL1 + 1))]\nCLIENT 
MERGE SORT";
++ "\nSERVER FILTER BY FIRST KEY ONLY\nSERVER 
AGGREGATE INTO ORDERED DISTINCT ROWS BY [TO_BIGINT(\"(A.INT_COL1 + 
1)\")]\nCLIENT MERGE SORT";
 assertEquals(expectedPlan, QueryUtil.getExplainPlan(rs));
 rs = conn.createStatement().executeQuery(sql);
 assertTrue(rs.next());
@@ -1202,54 +1202,60 @@ public class IndexExpressionIT extends 
BaseHBaseManagedTimeIT {
 
 @Test
 public void testViewUsesTableIndex() throws Exception {
-ResultSet rs;
 Connection conn = DriverManager.getConnection(getUrl());
-String ddl = "CREATE TABLE t (k1 INTEGER NOT NULL, k2 INTEGER NOT 
NULL, s1 VARCHAR, s2 VARCHAR, s3 VARCHAR, s4 VARCHAR CONSTRAINT pk PRIMARY KEY 
(k1, k2))";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("CREATE INDEX i1 ON t(k2, s2, s3, s1)");
-conn.createStatement().execute("CREATE INDEX i2 ON t(k2, s2||'_'||s3, 
s1, s4)");
-
-ddl = "CREATE VIEW v AS SELECT * FROM t WHERE s1 = 'foo'";
-conn.createStatement().execute(ddl);
-conn.createStatement().execute("UPSERT INTO t 
VALUES(1,1,'foo','abc','cab')");
-conn.createStatement().execute("UPSERT INTO t 
VALUES(2,2,'bar','xyz','zyx')");
-conn.commit();
-
-rs = conn.createStatement().executeQuery("SELECT count(*) FROM v");
-assertTrue(rs.next());
-assertEquals(1, rs.getLong(1));
-assertFalse(rs.next());
-
-//i2 should be used since it contains s3||'_'||s4 i
-String query = "SELECT s2||'_'||s3 FROM v WHERE k2=1 AND 
(s2||'_'||s3)='abc_cab'";
-rs = conn.createStatement(  ).executeQuery("EXPLAIN " + query);
-String queryPlan = QueryUtil.getExplainPlan(rs);
-assertEquals(
-"CLIENT PARALLEL 1-WAY RANGE SCAN OVER I2 

Build failed in Jenkins: Phoenix-4.x-HBase-1.x #5

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[gabrielr] PHOENIX-1653 Support separate clusters for MR jobs

--
[...truncated 127681 lines...]
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties:1964 ? 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisableWAL(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDisableWAL:728 ? PhoenixIO 
org.apache.hadoop.hbase.DoNotRetry...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable:697 
? PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnFromSaltedTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnFromSaltedTable:546 ? PhoenixIO 
org.apache.hadoop.h...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnsWithImutability(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnsWithImutability:823 ? PhoenixIO 
org.apache.hadoop
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropCoveredColumn(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropCoveredColumn:319 ? PhoenixIO 
org.apache.hadoop.hbase.DoN...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testDropVarCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropVarCols:673 ? PhoenixIO 
org.apache.hadoop.hbase.DoNotRetr...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:1302 ? PhoenixIO 
org.apac...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed:1213 ? 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols:1711
 ? PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cl

phoenix git commit: PHOENIX-1744 Allow Integer, UnsignedInt and UnsignedLong to be Cast to TIMESTAMP (Dave Hacker)

2015-03-24 Thread tdsilva
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.x 7de8ee1e9 -> 250474deb


PHOENIX-1744 Allow Integer, UnsignedInt and UnsignedLong to be Cast to 
TIMESTAMP (Dave Hacker)


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

Branch: refs/heads/4.x-HBase-1.x
Commit: 250474deb381b376d5ed442186470f65b36a8117
Parents: 7de8ee1
Author: David 
Authored: Wed Mar 18 13:37:20 2015 -0700
Committer: Thomas 
Committed: Tue Mar 24 14:00:20 2015 -0700

--
 .../phoenix/end2end/ToDateFunctionIT.java   | 57 
 .../phoenix/schema/types/PUnsignedLong.java |  5 ++
 2 files changed, 62 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/250474de/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
index bda4ea5..8de39b7 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
@@ -33,6 +33,7 @@ import java.sql.Timestamp;
 import java.util.Properties;
 
 import org.apache.phoenix.query.QueryServices;
+import org.apache.phoenix.schema.TypeMismatchException;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -176,4 +177,60 @@ public class ToDateFunctionIT extends 
BaseHBaseManagedTimeIT {
 callToDateFunction(
 customTimeZoneConn, "TO_DATE('1970-01-01', 
'-MM-dd')").getTime());
 }
+
+@Test
+public void testTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection customTimeZoneConn = DriverManager.getConnection(getUrl(), 
props);
+
+assertEquals(
+1426188807198L,
+callToDateFunction(
+customTimeZoneConn, "CAST(1426188807198 AS 
TIMESTAMP)").getTime());
+
+
+try {
+callToDateFunction(
+customTimeZoneConn, "CAST(22005 AS TIMESTAMP)");
+fail();
+} catch (TypeMismatchException e) {
+
+}
+}
+
+@Test
+public void testUnsignedLongToTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection conn = DriverManager.getConnection(getUrl(), props);
+conn.setAutoCommit(false);
+try {
+conn.prepareStatement(
+"create table TT("
++ "a unsigned_int not null, "
++ "b unsigned_int not null, "
++ "ts unsigned_long not null "
++ "constraint PK primary key (a, b, ts))").execute();
+conn.commit();
+
+conn.prepareStatement("upsert into TT values (0, 22120, 
1426188807198)").execute();
+conn.commit();
+
+ResultSet rs = conn.prepareStatement("select a, b, ts, CAST(ts AS 
TIMESTAMP) from TT").executeQuery();
+assertTrue(rs.next());
+assertEquals(new Date(1426188807198L), rs.getObject(4));
+rs.close();
+
+try {
+rs = conn.prepareStatement("select a, b, ts, CAST(b AS 
TIMESTAMP) from TT").executeQuery();
+fail();
+} catch (TypeMismatchException e) {
+
+}
+
+} finally {
+conn.close();
+}
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/250474de/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
index 67ae05a..a21ccc3 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
@@ -95,6 +95,11 @@ public class PUnsignedLong extends PWholeNumber {
   }
 
   @Override
+public boolean isCastableTo(PDataType targetType) {
+  return super.isCastableTo(targetType) || 
targetType.isCoercibleTo(PTimestamp.INSTANCE);
+}
+
+  @Override
   public boolean isCoercibleTo(PDataType targetType) {
 retu

Build failed in Jenkins: Phoenix | Master #634

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[gabrielr] PHOENIX-1653 Support separate clusters for MR jobs

--
[...truncated 127396 lines...]

org.apache.phoenix.end2end.AlterTableIT.testDropColumnsWithImutability(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnsWithImutability:823 » PhoenixIO 
org.apache.hadoop
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropCoveredColumn(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropCoveredColumn:319 » PhoenixIO 
org.apache.hadoop.hbase.DoN...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testDropVarCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropVarCols:673 » PhoenixIO 
org.apache.hadoop.hbase.DoNotRetr...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:1302 » PhoenixIO 
org.apac...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed:1213 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols:1711
 » PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHTableHColumnAndPhoenixTableProperties(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHTableHColumnAndPhoenixTableProperties:1063 » 
PhoenixIO or...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetPropertyAndAddColumnForDifferentColumnFamilies(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetPropertyAndAddColumnForDifferentColumnFamilies:1427 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testSetPropertyAndAddColumnForNewAndExistingColumnFamily(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetPropertyAndAddColumnForNewAndExistingColumnFamily:1351 » 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 » PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testSetPropertyAndAddColumnUsingDefaul

Apache-Phoenix | 4.x-HBase-0.98 | Build Successful

2015-03-24 Thread Apache Jenkins Server
4.x-HBase-0.98 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.x-HBase-0.98/lastSuccessfulBuild/artifact/

Test Report https://builds.apache.org/job/Phoenix-4.x-HBase-0.98/lastCompletedBuild/testReport/

Changes
[gabrielr] PHOENIX-1653 Support separate clusters for MR jobs



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 | 4.x-HBase-0.98 #602

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[gabrielr] PHOENIX-1653 Support separate clusters for MR jobs

--
[...truncated 442 lines...]
Running org.apache.phoenix.end2end.QueryMoreIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.069 sec - in 
org.apache.phoenix.end2end.UpsertSelectAutoCommitIT
Running org.apache.phoenix.end2end.BinaryRowKeyIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.503 sec - in 
org.apache.phoenix.end2end.BinaryRowKeyIT
Running org.apache.phoenix.end2end.TenantSpecificViewIndexIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.368 sec - in 
org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.MappingTableDataTypeIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.779 sec - in 
org.apache.phoenix.end2end.MappingTableDataTypeIT
Running org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.744 sec - in 
org.apache.phoenix.end2end.TenantSpecificViewIndexIT
Running org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.214 sec - in 
org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
Running org.apache.phoenix.end2end.SpooledSortMergeJoinIT
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.137 sec - in 
org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
Running org.apache.phoenix.end2end.SkipScanAfterManualSplitIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 92.8 sec - in 
org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Running org.apache.phoenix.end2end.StoreNullsIT
Tests run: 105, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 99.564 sec - 
in org.apache.phoenix.end2end.HashJoinIT
Running org.apache.phoenix.end2end.PhoenixRuntimeIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.17 sec - in 
org.apache.phoenix.end2end.SkipScanAfterManualSplitIT
Running org.apache.phoenix.end2end.RegexpSplitFunctionIT
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.049 sec - in 
org.apache.phoenix.end2end.RegexpSplitFunctionIT
Running org.apache.phoenix.end2end.StddevIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.781 sec - in 
org.apache.phoenix.end2end.StddevIT
Running org.apache.phoenix.end2end.SubqueryIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.771 sec - in 
org.apache.phoenix.end2end.StoreNullsIT
Running org.apache.phoenix.end2end.CoalesceFunctionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.908 sec - in 
org.apache.phoenix.end2end.PhoenixRuntimeIT
Running org.apache.phoenix.end2end.index.GlobalIndexOptimizationIT
Tests run: 105, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 96.428 sec - 
in org.apache.phoenix.end2end.SortMergeJoinIT
Running org.apache.phoenix.end2end.index.LocalIndexIT
Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.082 sec - in 
org.apache.phoenix.end2end.CoalesceFunctionIT
Running org.apache.phoenix.end2end.index.GlobalMutableIndexIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 29.271 sec - in 
org.apache.phoenix.end2end.index.GlobalIndexOptimizationIT
Running org.apache.phoenix.end2end.index.SaltedIndexIT
Tests run: 21, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 41.373 sec - 
in org.apache.phoenix.end2end.SubqueryIT
Running org.apache.phoenix.end2end.index.IndexMetadataIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.467 sec - in 
org.apache.phoenix.end2end.index.SaltedIndexIT
Running org.apache.phoenix.end2end.index.IndexExpressionIT
Tests run: 105, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 98.197 sec - 
in org.apache.phoenix.end2end.SpooledSortMergeJoinIT
Running org.apache.phoenix.end2end.index.DropViewIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.691 sec - in 
org.apache.phoenix.end2end.index.DropViewIT
Running org.apache.phoenix.end2end.index.LocalMutableIndexIT
Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 62.524 sec - 
in org.apache.phoenix.end2end.index.GlobalMutableIndexIT
Running org.apache.phoenix.end2end.index.ViewIndexIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 32.772 sec - in 
org.apache.phoenix.end2end.index.IndexMetadataIT
Running org.apache.phoenix.end2end.index.ImmutableIndexIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.818 sec - in 
org.apache.phoenix.end2end.index.ViewIndexIT
Running org.apache.phoenix.end2end.ServerExceptionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.214 sec - in 
org.apache.phoenix.end2end.ServerExceptionIT
Running org.apache.phoenix.end2end.CSVCommonsLoaderIT
Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.49 sec - in 
org.apache.phoenix.end2end.CSVCommonsLoa

phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs

2015-03-24 Thread greid
Repository: phoenix
Updated Branches:
  refs/heads/master 673847109 -> ab9c9283e


PHOENIX-1653 Support separate clusters for MR jobs

Add support for the input and output formats of a Phoenix MapReduce job to
point to separate clusters using override configuration settings. Defaults to
existing behavior (HConstants.ZOOKEEPER_QUORUM)


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

Branch: refs/heads/master
Commit: ab9c9283eca692b6f3ef03a598f4c012e63ef83a
Parents: 6738471
Author: gjacoby 
Authored: Fri Feb 27 16:49:14 2015 -0800
Committer: Gabriel Reid 
Committed: Tue Mar 24 20:08:08 2015 +0100

--
 .../phoenix/mapreduce/PhoenixInputFormat.java   | 15 ++--
 .../phoenix/mapreduce/PhoenixRecordWriter.java  |  2 +-
 .../phoenix/mapreduce/index/IndexTool.java  |  2 +-
 .../index/PhoenixIndexImportMapper.java |  2 +-
 .../phoenix/mapreduce/util/ConnectionUtil.java  | 88 ++--
 .../util/PhoenixConfigurationUtil.java  | 72 ++--
 .../mapreduce/util/PhoenixMapReduceUtil.java| 22 -
 .../util/PhoenixConfigurationUtilTest.java  | 60 -
 .../pig/util/QuerySchemaParserFunction.java |  2 +-
 .../pig/util/SqlQueryToColumnInfoFunction.java  |  2 +-
 10 files changed, 219 insertions(+), 48 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
index a83b9ae..31759b4 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
@@ -98,15 +98,16 @@ public class PhoenixInputFormat 
extends InputFormat 
extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
index 4d26bf4..5843076 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
@@ -46,7 +46,7 @@ public class PhoenixRecordWriter  
extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
index d93ef9c..300f575 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
@@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool {
 final String qDataTable = SchemaUtil.getTableName(schemaName, 
dataTable);
 final String qIndexTable = SchemaUtil.getTableName(schemaName, 
indexTable);
  
-connection = ConnectionUtil.getConnection(configuration);
+connection = ConnectionUtil.getInputConnection(configuration);
 if(!isValidIndexTable(connection, dataTable, indexTable)) {
 throw new IllegalArgumentException(String.format(" %s is not 
an index table for %s ",qIndexTable,qDataTable));
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
index 7bf4bfc..30f6dc0 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
@@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends 
Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/ab9c9283/pho

phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs

2015-03-24 Thread greid
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.x f4180fa40 -> 7de8ee1e9


PHOENIX-1653 Support separate clusters for MR jobs

Add support for the input and output formats of a Phoenix MapReduce job to
point to separate clusters using override configuration settings. Defaults to
existing behavior (HConstants.ZOOKEEPER_QUORUM)


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

Branch: refs/heads/4.x-HBase-1.x
Commit: 7de8ee1e914f5e0008ca9d983869757e4ca92b78
Parents: f4180fa
Author: gjacoby 
Authored: Fri Feb 27 16:49:14 2015 -0800
Committer: Gabriel Reid 
Committed: Tue Mar 24 20:07:52 2015 +0100

--
 .../phoenix/mapreduce/PhoenixInputFormat.java   | 15 ++--
 .../phoenix/mapreduce/PhoenixRecordWriter.java  |  2 +-
 .../phoenix/mapreduce/index/IndexTool.java  |  2 +-
 .../index/PhoenixIndexImportMapper.java |  2 +-
 .../phoenix/mapreduce/util/ConnectionUtil.java  | 88 ++--
 .../util/PhoenixConfigurationUtil.java  | 72 ++--
 .../mapreduce/util/PhoenixMapReduceUtil.java| 22 -
 .../util/PhoenixConfigurationUtilTest.java  | 60 -
 .../pig/util/QuerySchemaParserFunction.java |  2 +-
 .../pig/util/SqlQueryToColumnInfoFunction.java  |  2 +-
 10 files changed, 219 insertions(+), 48 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
index a83b9ae..31759b4 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
@@ -98,15 +98,16 @@ public class PhoenixInputFormat 
extends InputFormat 
extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
index 4d26bf4..5843076 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
@@ -46,7 +46,7 @@ public class PhoenixRecordWriter  
extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
index d93ef9c..300f575 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
@@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool {
 final String qDataTable = SchemaUtil.getTableName(schemaName, 
dataTable);
 final String qIndexTable = SchemaUtil.getTableName(schemaName, 
indexTable);
  
-connection = ConnectionUtil.getConnection(configuration);
+connection = ConnectionUtil.getInputConnection(configuration);
 if(!isValidIndexTable(connection, dataTable, indexTable)) {
 throw new IllegalArgumentException(String.format(" %s is not 
an index table for %s ",qIndexTable,qDataTable));
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/7de8ee1e/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
index 7bf4bfc..30f6dc0 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
@@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends 
Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/blo

phoenix git commit: PHOENIX-1653 Support separate clusters for MR jobs

2015-03-24 Thread greid
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 c92de2749 -> af0d65a0a


PHOENIX-1653 Support separate clusters for MR jobs

Add support for the input and output formats of a Phoenix MapReduce job to
point to separate clusters using override configuration settings. Defaults to
existing behavior (HConstants.ZOOKEEPER_QUORUM)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: af0d65a0abdbb8dc73d766a15e3ffa0e6d854d13
Parents: c92de27
Author: gjacoby 
Authored: Fri Feb 27 16:49:14 2015 -0800
Committer: Gabriel Reid 
Committed: Tue Mar 24 19:40:21 2015 +0100

--
 .../phoenix/mapreduce/PhoenixInputFormat.java   | 15 ++--
 .../phoenix/mapreduce/PhoenixRecordWriter.java  |  2 +-
 .../phoenix/mapreduce/index/IndexTool.java  |  2 +-
 .../index/PhoenixIndexImportMapper.java |  2 +-
 .../phoenix/mapreduce/util/ConnectionUtil.java  | 88 ++--
 .../util/PhoenixConfigurationUtil.java  | 72 ++--
 .../mapreduce/util/PhoenixMapReduceUtil.java| 22 -
 .../util/PhoenixConfigurationUtilTest.java  | 60 -
 .../pig/util/QuerySchemaParserFunction.java |  2 +-
 .../pig/util/SqlQueryToColumnInfoFunction.java  |  2 +-
 10 files changed, 219 insertions(+), 48 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
index a83b9ae..31759b4 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java
@@ -98,15 +98,16 @@ public class PhoenixInputFormat 
extends InputFormat 
extends InputFormathttp://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
index 4d26bf4..5843076 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java
@@ -46,7 +46,7 @@ public class PhoenixRecordWriter  
extends RecordWriterhttp://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
index d93ef9c..300f575 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java
@@ -163,7 +163,7 @@ public class IndexTool extends Configured implements Tool {
 final String qDataTable = SchemaUtil.getTableName(schemaName, 
dataTable);
 final String qIndexTable = SchemaUtil.getTableName(schemaName, 
indexTable);
  
-connection = ConnectionUtil.getConnection(configuration);
+connection = ConnectionUtil.getInputConnection(configuration);
 if(!isValidIndexTable(connection, dataTable, indexTable)) {
 throw new IllegalArgumentException(String.format(" %s is not 
an index table for %s ",qIndexTable,qDataTable));
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/af0d65a0/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
index 7bf4bfc..30f6dc0 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportMapper.java
@@ -73,7 +73,7 @@ public class PhoenixIndexImportMapper extends 
Mapperhttp://git-wip-us.apache.org/repos/asf/phoenix/b

Apache-Phoenix | 4.x-HBase-0.98 | Build Successful

2015-03-24 Thread Apache Jenkins Server
4.x-HBase-0.98 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.x-HBase-0.98/lastSuccessfulBuild/artifact/

Test Report https://builds.apache.org/job/Phoenix-4.x-HBase-0.98/lastCompletedBuild/testReport/

Changes
[samarth.jain] PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported (Dave Hacker)



Build times for last couple of runsLatest build time is the right most | Legend blue: normal, red: test failure, gray: timeout


Apache-Phoenix | 4.x-HBase-0.98 | Build Successful

2015-03-24 Thread Apache Jenkins Server
4.x-HBase-0.98 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.x-HBase-0.98/lastSuccessfulBuild/artifact/

Test Report https://builds.apache.org/job/Phoenix-4.x-HBase-0.98/lastCompletedBuild/testReport/

Changes
[samarth.jain] PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported (Dave Hacker)



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-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported (Dave Hacker)

2015-03-24 Thread samarth
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 790d5e4d1 -> c92de2749


PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported 
(Dave Hacker)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: c92de2749cc5d9954eb9381ecfa03affb615cc65
Parents: 790d5e4
Author: Samarth 
Authored: Tue Mar 24 10:20:39 2015 -0700
Committer: Samarth 
Committed: Tue Mar 24 10:20:39 2015 -0700

--
 .../phoenix/end2end/ToDateFunctionIT.java   | 57 
 .../phoenix/schema/types/PUnsignedLong.java |  5 ++
 2 files changed, 62 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c92de274/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
index bda4ea5..8de39b7 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
@@ -33,6 +33,7 @@ import java.sql.Timestamp;
 import java.util.Properties;
 
 import org.apache.phoenix.query.QueryServices;
+import org.apache.phoenix.schema.TypeMismatchException;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -176,4 +177,60 @@ public class ToDateFunctionIT extends 
BaseHBaseManagedTimeIT {
 callToDateFunction(
 customTimeZoneConn, "TO_DATE('1970-01-01', 
'-MM-dd')").getTime());
 }
+
+@Test
+public void testTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection customTimeZoneConn = DriverManager.getConnection(getUrl(), 
props);
+
+assertEquals(
+1426188807198L,
+callToDateFunction(
+customTimeZoneConn, "CAST(1426188807198 AS 
TIMESTAMP)").getTime());
+
+
+try {
+callToDateFunction(
+customTimeZoneConn, "CAST(22005 AS TIMESTAMP)");
+fail();
+} catch (TypeMismatchException e) {
+
+}
+}
+
+@Test
+public void testUnsignedLongToTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection conn = DriverManager.getConnection(getUrl(), props);
+conn.setAutoCommit(false);
+try {
+conn.prepareStatement(
+"create table TT("
++ "a unsigned_int not null, "
++ "b unsigned_int not null, "
++ "ts unsigned_long not null "
++ "constraint PK primary key (a, b, ts))").execute();
+conn.commit();
+
+conn.prepareStatement("upsert into TT values (0, 22120, 
1426188807198)").execute();
+conn.commit();
+
+ResultSet rs = conn.prepareStatement("select a, b, ts, CAST(ts AS 
TIMESTAMP) from TT").executeQuery();
+assertTrue(rs.next());
+assertEquals(new Date(1426188807198L), rs.getObject(4));
+rs.close();
+
+try {
+rs = conn.prepareStatement("select a, b, ts, CAST(b AS 
TIMESTAMP) from TT").executeQuery();
+fail();
+} catch (TypeMismatchException e) {
+
+}
+
+} finally {
+conn.close();
+}
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c92de274/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
index 67ae05a..a21ccc3 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
@@ -95,6 +95,11 @@ public class PUnsignedLong extends PWholeNumber {
   }
 
   @Override
+public boolean isCastableTo(PDataType targetType) {
+  return super.isCastableTo(targetType) || 
targetType.isCoercibleTo(PTimestamp.INSTANCE);
+}
+
+  @Override
   public boolean isCoercibleTo(PDataType targetType) {
 retu

Build failed in Jenkins: Phoenix | Master #633

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[samarth.jain] PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is 
not supported (Dave Hacker)

--
Started by an SCM change
Building remotely on ubuntu-5 (docker Ubuntu ubuntu5 ubuntu) in workspace 

 > git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
 > git config remote.origin.url 
 > https://git-wip-us.apache.org/repos/asf/phoenix.git # timeout=10
Fetching upstream changes from 
https://git-wip-us.apache.org/repos/asf/phoenix.git
 > git --version # timeout=10
 > git fetch --tags --progress 
 > https://git-wip-us.apache.org/repos/asf/phoenix.git 
 > +refs/heads/*:refs/remotes/origin/*
 > git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 673847109206ea1e73ae2a18258da304678a110f (origin/master)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f 673847109206ea1e73ae2a18258da304678a110f
 > git rev-list 898c7912149a81a0e287a4d82e5faa7163de6ce1 # timeout=10
No emails were triggered.
[Phoenix-master] $ /bin/bash -xe /tmp/hudson923732664369810261.sh
[Phoenix-master] $ /home/jenkins/tools/maven/apache-maven-3.0.4/bin/mvn clean 
install
[INFO] Scanning for projects...
[WARNING] 
[WARNING] Some problems were encountered while building the effective model for 
org.apache.phoenix:phoenix-core:jar:5.0.0-SNAPSHOT
[WARNING] 'build.plugins.plugin.(groupId:artifactId)' must be unique but found 
duplicate declaration of plugin 
org.apache.maven.plugins:maven-dependency-plugin @ line 204, column 15
[WARNING] 
[WARNING] It is highly recommended to fix these problems because they threaten 
the stability of your build.
[WARNING] 
[WARNING] For this reason, future Maven versions might no longer support 
building such malformed projects.
[WARNING] 
[INFO] 
[INFO] Reactor Build Order:
[INFO] 
[INFO] Apache Phoenix
[INFO] Phoenix Core
[INFO] Phoenix - Flume
[INFO] Phoenix - Pig
[INFO] Phoenix Assembly
[INFO] Phoenix - Pherf
[INFO] 
[INFO] 
[INFO] Building Apache Phoenix 5.0.0-SNAPSHOT
[INFO] 
[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix ---
[INFO] Deleting 
[INFO] 
[INFO] --- maven-remote-resources-plugin:1.5:process (default) @ phoenix ---
[INFO] 
[INFO] --- maven-source-plugin:2.2.1:jar-no-fork (attach-sources) @ phoenix ---
[INFO] 
[INFO] --- maven-jar-plugin:2.4:test-jar (default) @ phoenix ---
[WARNING] JAR will be empty - no content was marked for inclusion!
[INFO] Building jar: 

[INFO] 
[INFO] --- maven-site-plugin:3.2:attach-descriptor (attach-descriptor) @ 
phoenix ---
[INFO] 
[INFO] --- maven-install-plugin:2.5.1:install (default-install) @ phoenix ---
[INFO] Installing  to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix/5.0.0-SNAPSHOT/phoenix-5.0.0-SNAPSHOT.pom
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix/5.0.0-SNAPSHOT/phoenix-5.0.0-SNAPSHOT-tests.jar
[INFO] 
[INFO] 
[INFO] Building Phoenix Core 5.0.0-SNAPSHOT
[INFO] 
Downloading: 
http://people.apache.org/~garyh/mvn/org/apache/hbase/hbase-protocol/1.0.1-SNAPSHOT/maven-metadata.xml

[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix-core ---
[INFO] Deleting 

[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-source (add-test-source) @ 
phoenix-core ---
[INFO] Test Source directory: 
 
added.
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-resource 
(add-test-resource) @ phoenix-core ---
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-source (add-source) @ 
phoenix-core ---
[INFO] Source directory: 

 added.
[INFO] Source directory: 
 
added.
[INFO] 
[INFO] --- antlr3-maven-plugin:3.5:antlr (default) @ phoenix-core ---
[INFO] ANTLR: Processing source directory 


phoenix git commit: PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported (Dave Hacker)

2015-03-24 Thread samarth
Repository: phoenix
Updated Branches:
  refs/heads/4.3 236f40785 -> 362e37264


PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported 
(Dave Hacker)


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

Branch: refs/heads/4.3
Commit: 362e37264d9998928b2051ec917e7251ad48456d
Parents: 236f407
Author: Samarth 
Authored: Tue Mar 24 09:56:30 2015 -0700
Committer: Samarth 
Committed: Tue Mar 24 09:56:30 2015 -0700

--
 .../phoenix/end2end/ToDateFunctionIT.java   | 57 
 .../phoenix/schema/types/PUnsignedLong.java |  5 ++
 2 files changed, 62 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/362e3726/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
index bda4ea5..8de39b7 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
@@ -33,6 +33,7 @@ import java.sql.Timestamp;
 import java.util.Properties;
 
 import org.apache.phoenix.query.QueryServices;
+import org.apache.phoenix.schema.TypeMismatchException;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -176,4 +177,60 @@ public class ToDateFunctionIT extends 
BaseHBaseManagedTimeIT {
 callToDateFunction(
 customTimeZoneConn, "TO_DATE('1970-01-01', 
'-MM-dd')").getTime());
 }
+
+@Test
+public void testTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection customTimeZoneConn = DriverManager.getConnection(getUrl(), 
props);
+
+assertEquals(
+1426188807198L,
+callToDateFunction(
+customTimeZoneConn, "CAST(1426188807198 AS 
TIMESTAMP)").getTime());
+
+
+try {
+callToDateFunction(
+customTimeZoneConn, "CAST(22005 AS TIMESTAMP)");
+fail();
+} catch (TypeMismatchException e) {
+
+}
+}
+
+@Test
+public void testUnsignedLongToTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection conn = DriverManager.getConnection(getUrl(), props);
+conn.setAutoCommit(false);
+try {
+conn.prepareStatement(
+"create table TT("
++ "a unsigned_int not null, "
++ "b unsigned_int not null, "
++ "ts unsigned_long not null "
++ "constraint PK primary key (a, b, ts))").execute();
+conn.commit();
+
+conn.prepareStatement("upsert into TT values (0, 22120, 
1426188807198)").execute();
+conn.commit();
+
+ResultSet rs = conn.prepareStatement("select a, b, ts, CAST(ts AS 
TIMESTAMP) from TT").executeQuery();
+assertTrue(rs.next());
+assertEquals(new Date(1426188807198L), rs.getObject(4));
+rs.close();
+
+try {
+rs = conn.prepareStatement("select a, b, ts, CAST(b AS 
TIMESTAMP) from TT").executeQuery();
+fail();
+} catch (TypeMismatchException e) {
+
+}
+
+} finally {
+conn.close();
+}
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/362e3726/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
index a0ead11..005e2c4 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
@@ -94,6 +94,11 @@ public class PUnsignedLong extends PDataType {
   }
 
   @Override
+public boolean isCastableTo(PDataType targetType) {
+  return super.isCastableTo(targetType) || 
targetType.isCoercibleTo(PTimestamp.INSTANCE);
+}
+
+  @Override
   public boolean isCoercibleTo(PDataType targetType) {
 return targetType == this || 

phoenix git commit: PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported (Dave Hacker)

2015-03-24 Thread samarth
Repository: phoenix
Updated Branches:
  refs/heads/master 898c79121 -> 673847109


PHOENIX-1744 CAST from UNSIGNED_LONG (_INT) to * TIMESTAMP is not supported 
(Dave Hacker)


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

Branch: refs/heads/master
Commit: 673847109206ea1e73ae2a18258da304678a110f
Parents: 898c791
Author: Samarth 
Authored: Tue Mar 24 09:53:46 2015 -0700
Committer: Samarth 
Committed: Tue Mar 24 09:53:46 2015 -0700

--
 .../phoenix/end2end/ToDateFunctionIT.java   | 57 
 .../phoenix/schema/types/PUnsignedLong.java |  5 ++
 2 files changed, 62 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/67384710/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
index bda4ea5..8de39b7 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ToDateFunctionIT.java
@@ -33,6 +33,7 @@ import java.sql.Timestamp;
 import java.util.Properties;
 
 import org.apache.phoenix.query.QueryServices;
+import org.apache.phoenix.schema.TypeMismatchException;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -176,4 +177,60 @@ public class ToDateFunctionIT extends 
BaseHBaseManagedTimeIT {
 callToDateFunction(
 customTimeZoneConn, "TO_DATE('1970-01-01', 
'-MM-dd')").getTime());
 }
+
+@Test
+public void testTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection customTimeZoneConn = DriverManager.getConnection(getUrl(), 
props);
+
+assertEquals(
+1426188807198L,
+callToDateFunction(
+customTimeZoneConn, "CAST(1426188807198 AS 
TIMESTAMP)").getTime());
+
+
+try {
+callToDateFunction(
+customTimeZoneConn, "CAST(22005 AS TIMESTAMP)");
+fail();
+} catch (TypeMismatchException e) {
+
+}
+}
+
+@Test
+public void testUnsignedLongToTimestampCast() throws SQLException {
+Properties props = new Properties();
+props.setProperty(QueryServices.DATE_FORMAT_TIMEZONE_ATTRIB, "GMT+1");
+Connection conn = DriverManager.getConnection(getUrl(), props);
+conn.setAutoCommit(false);
+try {
+conn.prepareStatement(
+"create table TT("
++ "a unsigned_int not null, "
++ "b unsigned_int not null, "
++ "ts unsigned_long not null "
++ "constraint PK primary key (a, b, ts))").execute();
+conn.commit();
+
+conn.prepareStatement("upsert into TT values (0, 22120, 
1426188807198)").execute();
+conn.commit();
+
+ResultSet rs = conn.prepareStatement("select a, b, ts, CAST(ts AS 
TIMESTAMP) from TT").executeQuery();
+assertTrue(rs.next());
+assertEquals(new Date(1426188807198L), rs.getObject(4));
+rs.close();
+
+try {
+rs = conn.prepareStatement("select a, b, ts, CAST(b AS 
TIMESTAMP) from TT").executeQuery();
+fail();
+} catch (TypeMismatchException e) {
+
+}
+
+} finally {
+conn.close();
+}
+}
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/67384710/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
index 67ae05a..a21ccc3 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedLong.java
@@ -95,6 +95,11 @@ public class PUnsignedLong extends PWholeNumber {
   }
 
   @Override
+public boolean isCastableTo(PDataType targetType) {
+  return super.isCastableTo(targetType) || 
targetType.isCoercibleTo(PTimestamp.INSTANCE);
+}
+
+  @Override
   public boolean isCoercibleTo(PDataType targetType) {
 return targetType ==

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

2015-03-24 Thread Apache Jenkins Server
See 

Changes:

[thomas] PHOENIX-1676 Set priority of Index Updates correctly

[thomas] PHOENIX-1676 Set priority of Index Updates correctly, fix IndexQosIT

--
[...truncated 127763 lines...]
  Run 1: AlterTableIT.testAlterStoreNulls:1860 ? PhoenixIO 
org.apache.phoenix.exception...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testClientCacheUpdatedOnChangingPhoenixTableProperties:1964 ? 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisableWAL(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDisableWAL:728 ? PhoenixIO 
org.apache.hadoop.hbase.DoNotRetry...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testDisallowAddingNotNullableColumnNotPartOfPkForExistingTable:697 
? PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnFromSaltedTable(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnFromSaltedTable:546 ? PhoenixIO 
org.apache.hadoop.h...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropColumnsWithImutability(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropColumnsWithImutability:823 ? PhoenixIO 
org.apache.hadoop
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testDropCoveredColumn(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropCoveredColumn:319 ? PhoenixIO 
org.apache.hadoop.hbase.DoN...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testDropVarCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testDropVarCols:673 ? PhoenixIO 
org.apache.hadoop.hbase.DoNotRetr...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

org.apache.phoenix.end2end.AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:1302 ? PhoenixIO 
org.apac...
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: AlterTableIT.testSetHColumnOrHTablePropertiesOnViewsNotAllowed:1213 ? 
PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO

  
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAfterTest:29->BaseTest.deletePriorTables:766->BaseTest.deletePriorTables:777->BaseTest.deletePriorTables:794
 ? PhoenixIO
org.apache.phoenix.end2end.AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols(org.apache.phoenix.end2end.AlterTableIT)
  Run 1: 
AlterTableIT.testSetHColumnPropertyAndAddColumnForDefaultCFForTableWithOnlyPKCols:1711
 ? PhoenixIO
  Run 2: 
AlterTableIT>BaseOwnClusterHBaseManagedTimeIT.cleanUpAft