Build failed in Jenkins: Phoenix | Master #1803

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[jamestaylor] PHOENIX-4212 Disallow DML operations on connections with 
CURRENT_SCN set

--
[...truncated 101.84 KB...]
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.392 s 
- in org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
[INFO] Running org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.846 s 
- in org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Running org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Tests run: 67, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 439.886 
s - in org.apache.phoenix.end2end.index.IndexExpressionIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 33.458 s 
- in org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Running org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 52.724 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.433 s 
- in org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 29.078 s 
- in org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Running org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.138 s 
- in org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.97 s - 
in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 46.492 s 
- in org.apache.phoenix.tx.TransactionIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 87.693 s 
- in org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Tests run: 102, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
1,117.816 s - in org.apache.phoenix.end2end.SortMergeJoinIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.435 s 
- in org.apache.phoenix.util.IndexScrutinyIT
[WARNING] Tests run: 52, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
194.372 s - in org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 274.097 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 729.855 
s - in org.apache.phoenix.end2end.index.MutableIndexSplitForwardScanIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 690.536 
s - in org.apache.phoenix.end2end.index.MutableIndexSplitReverseScanIT
[INFO] Tests run: 320, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
2,004.786 s - in org.apache.phoenix.end2end.index.IndexIT
[INFO] 
[INFO] Results:
[INFO] 
[WARNING] Tests run: 3430, Failures: 0, Errors: 0, Skipped: 5
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (ClientManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running org.apache.phoenix.end2end.UpsertValuesIT
[INFO] Running org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 56.008 
s - in org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 25, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 115.913 
s - in org.apache.phoenix.end2end.UpsertValuesIT
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 75, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (HBaseManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test 
(NeedTheirOwnClusterTests) @ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running 

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

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[jamestaylor] PHOENIX-4212 Disallow DML operations on connections with 
CURRENT_SCN set

--
[...truncated 95.43 KB...]
[INFO] Running org.apache.phoenix.end2end.StringIT
[INFO] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 41.609 
s - in org.apache.phoenix.end2end.StringIT
[INFO] Running org.apache.phoenix.end2end.StringToArrayFunctionIT
[INFO] Tests run: 22, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 39.38 s 
- in org.apache.phoenix.end2end.StringToArrayFunctionIT
[INFO] Running org.apache.phoenix.end2end.SubqueryIT
[INFO] Tests run: 32, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 209.203 
s - in org.apache.phoenix.end2end.StoreNullsIT
[INFO] Running org.apache.phoenix.end2end.SubqueryUsingSortMergeJoinIT
[INFO] Tests run: 21, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 171.157 
s - in org.apache.phoenix.end2end.SubqueryIT
[INFO] Running org.apache.phoenix.end2end.TenantIdTypeIT
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 138.678 
s - in org.apache.phoenix.end2end.SubqueryUsingSortMergeJoinIT
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 40.892 
s - in org.apache.phoenix.end2end.TenantIdTypeIT
[INFO] Running org.apache.phoenix.end2end.TenantSpecificViewIndexSaltedIT
[INFO] Running org.apache.phoenix.end2end.TenantSpecificViewIndexIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 31.535 s 
- in org.apache.phoenix.end2end.TenantSpecificViewIndexSaltedIT
[INFO] Running org.apache.phoenix.end2end.TimezoneOffsetFunctionIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.849 s 
- in org.apache.phoenix.end2end.TimezoneOffsetFunctionIT
[INFO] Running org.apache.phoenix.end2end.ToCharFunctionIT
[INFO] Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 76.15 s 
- in org.apache.phoenix.end2end.TenantSpecificViewIndexIT
[INFO] Running org.apache.phoenix.end2end.ToDateFunctionIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.018 s 
- in org.apache.phoenix.end2end.ToDateFunctionIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 22.279 
s - in org.apache.phoenix.end2end.ToCharFunctionIT
[INFO] Running org.apache.phoenix.end2end.TopNIT
[INFO] Running org.apache.phoenix.end2end.ToNumberFunctionIT
[INFO] Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.2 s - 
in org.apache.phoenix.end2end.ToNumberFunctionIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.322 s 
- in org.apache.phoenix.end2end.TopNIT
[INFO] Running org.apache.phoenix.end2end.UnionAllIT
[INFO] Tests run: 102, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
928.647 s - in org.apache.phoenix.end2end.SortMergeJoinIT
[INFO] Running org.apache.phoenix.end2end.TruncateFunctionIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.803 s 
- in org.apache.phoenix.end2end.TruncateFunctionIT
[INFO] Running org.apache.phoenix.end2end.UpsertBigValuesIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.39 s - 
in org.apache.phoenix.end2end.UpsertBigValuesIT
[INFO] Running org.apache.phoenix.end2end.UpsertSelectAutoCommitIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.398 s 
- in org.apache.phoenix.end2end.UpsertSelectAutoCommitIT
[INFO] Running org.apache.phoenix.end2end.UpsertSelectIT
[INFO] Running org.apache.phoenix.end2end.UpgradeIT
[INFO] Tests run: 17, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 63.871 
s - in org.apache.phoenix.end2end.UnionAllIT
[INFO] Running org.apache.phoenix.end2end.UseSchemaIT
[INFO] Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.919 s 
- in org.apache.phoenix.end2end.UseSchemaIT
[INFO] Running org.apache.phoenix.end2end.index.AsyncIndexDisabledIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.503 s 
- in org.apache.phoenix.end2end.index.AsyncIndexDisabledIT
[INFO] Running org.apache.phoenix.end2end.index.ChildViewsUseParentViewIndexIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.624 s 
- in org.apache.phoenix.end2end.index.ChildViewsUseParentViewIndexIT
[INFO] Running org.apache.phoenix.end2end.index.DropColumnIT
[INFO] Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 90.165 
s - in org.apache.phoenix.end2end.UpsertSelectIT
[INFO] Running org.apache.phoenix.end2end.index.DropMetadataIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.351 s 
- in org.apache.phoenix.end2end.index.DropMetadataIT
[INFO] Running org.apache.phoenix.end2end.index.GlobalIndexOptimizationIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 26.943 s 
- in org.apache.phoenix.end2end.index.GlobalIndexOptimizationIT
[INFO] Running 

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

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[jamestaylor] PHOENIX-4212 Disallow DML operations on connections with 
CURRENT_SCN set

--
[...truncated 543.23 KB...]
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.395 s 
- in org.apache.phoenix.end2end.salted.SaltedTableIT
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 64.392 s 
- in org.apache.phoenix.end2end.index.txn.MutableRollbackIT
[INFO] Running org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.345 s 
- in org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
[INFO] Running org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.336 s 
- in org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Running org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.098 s 
- in org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Running org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 29.257 s 
- in org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Running org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.347 s 
- in org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.447 s 
- in org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Running org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.94 s - 
in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 50.934 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 67, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 429.54 
s - in org.apache.phoenix.end2end.index.IndexExpressionIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 78.197 s 
- in org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 50.272 s 
- in org.apache.phoenix.tx.TransactionIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.003 s 
- in org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 64, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 442.271 
s - in org.apache.phoenix.end2end.index.MutableIndexIT
[INFO] Tests run: 102, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
1,023.853 s - in org.apache.phoenix.end2end.SortMergeJoinIT
[WARNING] Tests run: 52, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
189.768 s - in org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 268.475 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 320, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
2,011.538 s - in org.apache.phoenix.end2end.index.IndexIT
[INFO] 
[INFO] Results:
[INFO] 
[ERROR] Errors: 
[ERROR]   FlappingAlterTableIT.testAddColumnForNewColumnFamily:60 » PhoenixIO 
org.apache...
[ERROR]   FlappingAlterTableIT.testNewColumnFamilyInheritsTTLOfEmptyCF:84 » 
PhoenixIO or...
[INFO] 
[ERROR] Tests run: 3487, Failures: 0, Errors: 2, Skipped: 5
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (ClientManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running org.apache.phoenix.end2end.UpsertValuesIT
[INFO] Running org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 58.184 
s - in org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 25, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 118.115 
s - in org.apache.phoenix.end2end.UpsertValuesIT
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 75, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (HBaseManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 

Build failed in Jenkins: Phoenix | Master #1802

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[jamestaylor] PHOENIX-4212 Disallow DML operations on connections with 
CURRENT_SCN set

--
[...truncated 99.44 KB...]
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.837 s 
- in org.apache.phoenix.end2end.TopNIT
[INFO] Running org.apache.phoenix.end2end.UnionAllIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.254 s 
- in org.apache.phoenix.end2end.TimezoneOffsetFunctionIT
[INFO] Running org.apache.phoenix.end2end.UpgradeIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.431 s 
- in org.apache.phoenix.end2end.ToDateFunctionIT
[INFO] Running org.apache.phoenix.end2end.UpperLowerFunctionIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.055 s 
- in org.apache.phoenix.end2end.UpperLowerFunctionIT
[INFO] Running org.apache.phoenix.end2end.UpsertBigValuesIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.676 s 
- in org.apache.phoenix.end2end.UpsertBigValuesIT
[INFO] Running org.apache.phoenix.end2end.UpsertSelectAutoCommitIT
[INFO] Running org.apache.phoenix.end2end.TruncateFunctionIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.378 s 
- in org.apache.phoenix.end2end.TruncateFunctionIT
[INFO] Running org.apache.phoenix.end2end.UpsertSelectIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.859 s 
- in org.apache.phoenix.end2end.UpsertSelectAutoCommitIT
[INFO] Running org.apache.phoenix.end2end.UseSchemaIT
[INFO] Tests run: 112, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
716.079 s - in org.apache.phoenix.end2end.QueryIT
[INFO] Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 28.876 s 
- in org.apache.phoenix.end2end.UseSchemaIT
[INFO] Running org.apache.phoenix.end2end.index.ChildViewsUseParentViewIndexIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.91 s - 
in org.apache.phoenix.end2end.index.ChildViewsUseParentViewIndexIT
[INFO] Running org.apache.phoenix.end2end.index.AsyncIndexDisabledIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.685 s 
- in org.apache.phoenix.end2end.index.AsyncIndexDisabledIT
[INFO] Running org.apache.phoenix.end2end.index.DropMetadataIT
[INFO] Tests run: 17, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 85.406 
s - in org.apache.phoenix.end2end.UnionAllIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.037 s 
- in org.apache.phoenix.end2end.index.DropMetadataIT
[INFO] Running org.apache.phoenix.end2end.index.IndexExpressionIT
[INFO] Running org.apache.phoenix.end2end.index.DropColumnIT
[INFO] Running org.apache.phoenix.end2end.index.GlobalIndexOptimizationIT
[INFO] Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 110.951 
s - in org.apache.phoenix.end2end.UpsertSelectIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 36.288 s 
- in org.apache.phoenix.end2end.index.GlobalIndexOptimizationIT
[INFO] Running org.apache.phoenix.end2end.index.IndexMetadataIT
[INFO] Running org.apache.phoenix.end2end.index.IndexIT
[INFO] Tests run: 245, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
2,011.087 s - in org.apache.phoenix.end2end.ClientTimeArithmeticQueryIT
[INFO] Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 44.159 
s - in org.apache.phoenix.end2end.index.IndexMetadataIT
[INFO] Running org.apache.phoenix.end2end.index.MutableIndexSplitForwardScanIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 239.582 
s - in org.apache.phoenix.end2end.UpgradeIT
[INFO] Running org.apache.phoenix.end2end.index.MutableIndexIT
[INFO] Tests run: 119, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
752.163 s - in org.apache.phoenix.end2end.ScanQueryIT
[INFO] Running org.apache.phoenix.end2end.index.MutableIndexSplitReverseScanIT
[INFO] Running org.apache.phoenix.end2end.index.SaltedIndexIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.618 s 
- in org.apache.phoenix.end2end.index.SaltedIndexIT
[INFO] Running org.apache.phoenix.end2end.index.ViewIndexIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 51.563 s 
- in org.apache.phoenix.end2end.index.ViewIndexIT
[INFO] Running org.apache.phoenix.end2end.index.txn.MutableRollbackIT
[INFO] Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 311.281 
s - in org.apache.phoenix.end2end.index.DropColumnIT
[INFO] Running org.apache.phoenix.end2end.index.txn.RollbackIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 66.961 s 
- in org.apache.phoenix.end2end.index.txn.MutableRollbackIT
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.548 s 
- in org.apache.phoenix.end2end.salted.SaltedTableIT
[INFO] 

phoenix git commit: PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - DerivedTableIT (Ethan Wang)

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/master 415c6e352 -> df5b0d213


PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - 
DerivedTableIT (Ethan Wang)


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

Branch: refs/heads/master
Commit: df5b0d213887ef79b83d1e4dbf15dce8d128272f
Parents: 415c6e3
Author: James Taylor 
Authored: Fri Sep 15 17:05:08 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 17:05:08 2017 -0700

--
 .../src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/df5b0d21/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
index 789659d..265ad21 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
@@ -48,7 +48,7 @@ import org.apache.phoenix.util.QueryUtil;
 import org.junit.Test;
 
 public class DerivedTableIT extends ParallelStatsDisabledIT {
-public String[] initTableWithIndex(String tableName) throws Exception {
+private static String[] initTableWithIndex(String tableName) throws 
Exception {
 String tenantId = getOrganizationId();
 initATableValues(tableName, tenantId, getDefaultSplits(tenantId), 
null, null, getUrl(), null);
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
@@ -73,7 +73,7 @@ public class DerivedTableIT extends ParallelStatsDisabledIT {
 return plans;
 }
 
-public String[] initTableWithoutIndex(String tableName) throws Exception {
+private static String[] initTableWithoutIndex(String tableName) throws 
Exception {
 String tenantId = getOrganizationId();
 initATableValues(tableName, tenantId, getDefaultSplits(tenantId), 
null, null, getUrl(), null);
 String[] plans= {"CLIENT PARALLEL 4-WAY FULL SCAN OVER 
"+tableName+"\n" +



phoenix git commit: PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - DerivedTableIT (Ethan Wang)

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.2 b37ccb52d -> b2774c5b5


PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - 
DerivedTableIT (Ethan Wang)


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

Branch: refs/heads/4.x-HBase-1.2
Commit: b2774c5b5f9f0dfd6edc593c0783417f027dccea
Parents: b37ccb5
Author: James Taylor 
Authored: Fri Sep 15 16:30:03 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 17:00:17 2017 -0700

--
 .../apache/phoenix/end2end/DerivedTableIT.java  | 1166 +++---
 1 file changed, 975 insertions(+), 191 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/b2774c5b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
index 39fb747..265ad21 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
@@ -18,7 +18,6 @@
 
 package org.apache.phoenix.end2end;
 
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 import static org.apache.phoenix.util.TestUtil.A_VALUE;
 import static org.apache.phoenix.util.TestUtil.B_VALUE;
 import static org.apache.phoenix.util.TestUtil.C_VALUE;
@@ -42,100 +41,68 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
-import java.util.Collection;
-import java.util.List;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
-import org.junit.Before;
 import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameters;
-
-import com.google.common.collect.Lists;
-
-
-@RunWith(Parameterized.class)
-public class DerivedTableIT extends BaseClientManagedTimeIT {
-private static final String tenantId = getOrganizationId();
-
-private long ts;
-private String[] indexDDL;
-private String[] plans;
-
-public DerivedTableIT(String[] indexDDL, String[] plans) {
-this.indexDDL = indexDDL;
-this.plans = plans;
-}
-
-@Before
-public void initTable() throws Exception {
- ts = nextTimestamp();
-initATableValues(ATABLE_NAME, tenantId, getDefaultSplits(tenantId), 
null, ts, getUrl(), null);
-if (indexDDL != null && indexDDL.length > 0) {
-Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts));
-Connection conn = DriverManager.getConnection(getUrl(), props);
-for (String ddl : indexDDL) {
-conn.createStatement().execute(ddl);
-}
-}
-}
-
-@Parameters(name="DerivedTableIT_{index}") // name is used by failsafe as 
file name in reports
-public static Collection data() {
-List testCases = Lists.newArrayList();
-testCases.add(new String[][] {
-{ 
-"CREATE INDEX ATABLE_DERIVED_IDX ON aTable (a_byte) INCLUDE 
(A_STRING, B_STRING)" 
-}, {
-"CLIENT PARALLEL 1-WAY FULL SCAN OVER ATABLE_DERIVED_IDX\n" +
+
+public class DerivedTableIT extends ParallelStatsDisabledIT {
+private static String[] initTableWithIndex(String tableName) throws 
Exception {
+String tenantId = getOrganizationId();
+initATableValues(tableName, tenantId, getDefaultSplits(tenantId), 
null, null, getUrl(), null);
+Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
+Connection conn = DriverManager.getConnection(getUrl(), props);
+String ddl="CREATE INDEX "+tableName+"_DERIVED_IDX ON "+tableName+" 
(a_byte) INCLUDE (A_STRING, B_STRING)";
+conn.createStatement().execute(ddl);
+String[] plans= {"CLIENT PARALLEL 1-WAY FULL SCAN OVER 
"+tableName+"_DERIVED_IDX\n" +
 "SERVER AGGREGATE INTO DISTINCT ROWS BY [\"A_STRING\", 
\"B_STRING\"]\n" +
 "CLIENT MERGE SORT\n" +
 "CLIENT SORTED BY [\"B_STRING\"]\n" +
 "CLIENT SORTED BY [A]\n" +
 "CLIENT AGGREGATE INTO DISTINCT ROWS BY [A]\n" +
 "CLIENT SORTED BY [A DESC]",
-
-   

phoenix git commit: PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - DerivedTableIT (Ethan Wang)

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 4348212a3 -> 2c53fa56f


PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - 
DerivedTableIT (Ethan Wang)


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

Branch: refs/heads/4.x-HBase-1.1
Commit: 2c53fa56fced927021f8ab04a703e0f0987627e0
Parents: 4348212
Author: James Taylor 
Authored: Fri Sep 15 16:30:03 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 16:59:10 2017 -0700

--
 .../apache/phoenix/end2end/DerivedTableIT.java  | 1166 +++---
 1 file changed, 975 insertions(+), 191 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/2c53fa56/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
index 39fb747..265ad21 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
@@ -18,7 +18,6 @@
 
 package org.apache.phoenix.end2end;
 
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 import static org.apache.phoenix.util.TestUtil.A_VALUE;
 import static org.apache.phoenix.util.TestUtil.B_VALUE;
 import static org.apache.phoenix.util.TestUtil.C_VALUE;
@@ -42,100 +41,68 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
-import java.util.Collection;
-import java.util.List;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
-import org.junit.Before;
 import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameters;
-
-import com.google.common.collect.Lists;
-
-
-@RunWith(Parameterized.class)
-public class DerivedTableIT extends BaseClientManagedTimeIT {
-private static final String tenantId = getOrganizationId();
-
-private long ts;
-private String[] indexDDL;
-private String[] plans;
-
-public DerivedTableIT(String[] indexDDL, String[] plans) {
-this.indexDDL = indexDDL;
-this.plans = plans;
-}
-
-@Before
-public void initTable() throws Exception {
- ts = nextTimestamp();
-initATableValues(ATABLE_NAME, tenantId, getDefaultSplits(tenantId), 
null, ts, getUrl(), null);
-if (indexDDL != null && indexDDL.length > 0) {
-Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts));
-Connection conn = DriverManager.getConnection(getUrl(), props);
-for (String ddl : indexDDL) {
-conn.createStatement().execute(ddl);
-}
-}
-}
-
-@Parameters(name="DerivedTableIT_{index}") // name is used by failsafe as 
file name in reports
-public static Collection data() {
-List testCases = Lists.newArrayList();
-testCases.add(new String[][] {
-{ 
-"CREATE INDEX ATABLE_DERIVED_IDX ON aTable (a_byte) INCLUDE 
(A_STRING, B_STRING)" 
-}, {
-"CLIENT PARALLEL 1-WAY FULL SCAN OVER ATABLE_DERIVED_IDX\n" +
+
+public class DerivedTableIT extends ParallelStatsDisabledIT {
+private static String[] initTableWithIndex(String tableName) throws 
Exception {
+String tenantId = getOrganizationId();
+initATableValues(tableName, tenantId, getDefaultSplits(tenantId), 
null, null, getUrl(), null);
+Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
+Connection conn = DriverManager.getConnection(getUrl(), props);
+String ddl="CREATE INDEX "+tableName+"_DERIVED_IDX ON "+tableName+" 
(a_byte) INCLUDE (A_STRING, B_STRING)";
+conn.createStatement().execute(ddl);
+String[] plans= {"CLIENT PARALLEL 1-WAY FULL SCAN OVER 
"+tableName+"_DERIVED_IDX\n" +
 "SERVER AGGREGATE INTO DISTINCT ROWS BY [\"A_STRING\", 
\"B_STRING\"]\n" +
 "CLIENT MERGE SORT\n" +
 "CLIENT SORTED BY [\"B_STRING\"]\n" +
 "CLIENT SORTED BY [A]\n" +
 "CLIENT AGGREGATE INTO DISTINCT ROWS BY [A]\n" +
 "CLIENT SORTED BY [A DESC]",
-
-   

phoenix git commit: PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - DerivedTableIT (Ethan Wang)

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 b46b735f0 -> b0d319b73


PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - 
DerivedTableIT (Ethan Wang)

Conflicts:

phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java


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

Branch: refs/heads/4.x-HBase-0.98
Commit: b0d319b73933e587c8c4b037f80423a824581185
Parents: b46b735
Author: James Taylor 
Authored: Fri Sep 15 16:30:03 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 16:49:19 2017 -0700

--
 .../apache/phoenix/end2end/DerivedTableIT.java  | 1168 +++---
 1 file changed, 977 insertions(+), 191 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/b0d319b7/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
index 224bb44..3bbd347 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
@@ -18,7 +18,6 @@
 
 package org.apache.phoenix.end2end;
 
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 import static org.apache.phoenix.util.TestUtil.A_VALUE;
 import static org.apache.phoenix.util.TestUtil.B_VALUE;
 import static org.apache.phoenix.util.TestUtil.C_VALUE;
@@ -42,99 +41,68 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
-import java.util.Collection;
-import java.util.List;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
-import org.junit.Before;
 import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameters;
-
-import com.google.common.collect.Lists;
-
-@RunWith(Parameterized.class)
-public class DerivedTableIT extends BaseClientManagedTimeIT {
-private static final String tenantId = getOrganizationId();
-
-private long ts;
-private String[] indexDDL;
-private String[] plans;
-
-public DerivedTableIT(String[] indexDDL, String[] plans) {
-this.indexDDL = indexDDL;
-this.plans = plans;
-}
-
-@Before
-public void initTable() throws Exception {
- ts = nextTimestamp();
-initATableValues(ATABLE_NAME, tenantId, getDefaultSplits(tenantId), 
null, ts, getUrl(), null);
-if (indexDDL != null && indexDDL.length > 0) {
-Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts));
-Connection conn = DriverManager.getConnection(getUrl(), props);
-for (String ddl : indexDDL) {
-conn.createStatement().execute(ddl);
-}
-}
-}
-
-@Parameters(name="DerivedTableIT_{index}") // name is used by failsafe as 
file name in reports
-public static Collection data() {
-List testCases = Lists.newArrayList();
-testCases.add(new String[][] {
-{ 
-"CREATE INDEX ATABLE_DERIVED_IDX ON aTable (a_byte) INCLUDE 
(A_STRING, B_STRING)" 
-}, {
-"CLIENT PARALLEL 1-WAY FULL SCAN OVER ATABLE_DERIVED_IDX\n" +
+
+public class DerivedTableIT extends ParallelStatsDisabledIT {
+private static String[] initTableWithIndex(String tableName) throws 
Exception {
+String tenantId = getOrganizationId();
+initATableValues(tableName, tenantId, getDefaultSplits(tenantId), 
null, null, getUrl(), null);
+Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
+Connection conn = DriverManager.getConnection(getUrl(), props);
+String ddl="CREATE INDEX "+tableName+"_DERIVED_IDX ON "+tableName+" 
(a_byte) INCLUDE (A_STRING, B_STRING)";
+conn.createStatement().execute(ddl);
+String[] plans= {"CLIENT PARALLEL 1-WAY FULL SCAN OVER 
"+tableName+"_DERIVED_IDX\n" +
 "SERVER AGGREGATE INTO DISTINCT ROWS BY [\"A_STRING\", 
\"B_STRING\"]\n" +
 "CLIENT MERGE SORT\n" +
 "CLIENT SORTED BY [\"B_STRING\"]\n" +
 "CLIENT SORTED BY [A]\n" +
 "CLIENT AGGREGATE INTO 

phoenix git commit: PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - DerivedTableIT (Ethan Wang)

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/master c06ef877e -> 415c6e352


PHOENIX-4212 Disallow DML operations on connections with CURRENT_SCN set - 
DerivedTableIT (Ethan Wang)


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

Branch: refs/heads/master
Commit: 415c6e3523bc42f82178c163b891fc5eb22f6a96
Parents: c06ef87
Author: James Taylor 
Authored: Fri Sep 15 16:30:03 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 16:30:03 2017 -0700

--
 .../apache/phoenix/end2end/DerivedTableIT.java  | 1166 +++---
 1 file changed, 975 insertions(+), 191 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/415c6e35/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
index 39fb747..789659d 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DerivedTableIT.java
@@ -18,7 +18,6 @@
 
 package org.apache.phoenix.end2end;
 
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 import static org.apache.phoenix.util.TestUtil.A_VALUE;
 import static org.apache.phoenix.util.TestUtil.B_VALUE;
 import static org.apache.phoenix.util.TestUtil.C_VALUE;
@@ -42,100 +41,68 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
-import java.util.Collection;
-import java.util.List;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
-import org.junit.Before;
 import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameters;
-
-import com.google.common.collect.Lists;
-
-
-@RunWith(Parameterized.class)
-public class DerivedTableIT extends BaseClientManagedTimeIT {
-private static final String tenantId = getOrganizationId();
-
-private long ts;
-private String[] indexDDL;
-private String[] plans;
-
-public DerivedTableIT(String[] indexDDL, String[] plans) {
-this.indexDDL = indexDDL;
-this.plans = plans;
-}
-
-@Before
-public void initTable() throws Exception {
- ts = nextTimestamp();
-initATableValues(ATABLE_NAME, tenantId, getDefaultSplits(tenantId), 
null, ts, getUrl(), null);
-if (indexDDL != null && indexDDL.length > 0) {
-Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts));
-Connection conn = DriverManager.getConnection(getUrl(), props);
-for (String ddl : indexDDL) {
-conn.createStatement().execute(ddl);
-}
-}
-}
-
-@Parameters(name="DerivedTableIT_{index}") // name is used by failsafe as 
file name in reports
-public static Collection data() {
-List testCases = Lists.newArrayList();
-testCases.add(new String[][] {
-{ 
-"CREATE INDEX ATABLE_DERIVED_IDX ON aTable (a_byte) INCLUDE 
(A_STRING, B_STRING)" 
-}, {
-"CLIENT PARALLEL 1-WAY FULL SCAN OVER ATABLE_DERIVED_IDX\n" +
+
+public class DerivedTableIT extends ParallelStatsDisabledIT {
+public String[] initTableWithIndex(String tableName) throws Exception {
+String tenantId = getOrganizationId();
+initATableValues(tableName, tenantId, getDefaultSplits(tenantId), 
null, null, getUrl(), null);
+Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
+Connection conn = DriverManager.getConnection(getUrl(), props);
+String ddl="CREATE INDEX "+tableName+"_DERIVED_IDX ON "+tableName+" 
(a_byte) INCLUDE (A_STRING, B_STRING)";
+conn.createStatement().execute(ddl);
+String[] plans= {"CLIENT PARALLEL 1-WAY FULL SCAN OVER 
"+tableName+"_DERIVED_IDX\n" +
 "SERVER AGGREGATE INTO DISTINCT ROWS BY [\"A_STRING\", 
\"B_STRING\"]\n" +
 "CLIENT MERGE SORT\n" +
 "CLIENT SORTED BY [\"B_STRING\"]\n" +
 "CLIENT SORTED BY [A]\n" +
 "CLIENT AGGREGATE INTO DISTINCT ROWS BY [A]\n" +
 "CLIENT SORTED BY [A DESC]",
-
-"CLIENT 

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

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[mujtaba] PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use

[mujtaba] PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use 
currentSCN

[mujtaba] PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN

--
[...truncated 106.63 KB...]
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test 
(NeedTheirOwnClusterTests) @ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 36.179 s 
- in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.146 s 
- in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.549 s 
- in org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.789 s 
- in org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.863 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running org.apache.phoenix.end2end.DropSchemaIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.959 s 
- in org.apache.phoenix.end2end.DropSchemaIT
[INFO] Running org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running org.apache.phoenix.end2end.IndexScrutinyToolIT
[INFO] Running org.apache.phoenix.end2end.IndexExtendedIT
[INFO] Running org.apache.phoenix.end2end.IndexToolForPartialBuildIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 78.721 
s - in org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 26.622 s 
- in org.apache.phoenix.end2end.IndexToolForPartialBuildIT
[INFO] Running 
org.apache.phoenix.end2end.IndexToolForPartialBuildWithNamespaceEnabledIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 26.269 s 
- in org.apache.phoenix.end2end.IndexToolForPartialBuildWithNamespaceEnabledIT
[INFO] Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 82.926 
s - in org.apache.phoenix.end2end.IndexScrutinyToolIT
[INFO] Running org.apache.phoenix.end2end.QueryTimeoutIT
[INFO] Running org.apache.phoenix.end2end.QueryWithLimitIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.563 s 
- in org.apache.phoenix.end2end.QueryWithLimitIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 20.123 s 
- in org.apache.phoenix.end2end.QueryTimeoutIT
[INFO] Running org.apache.phoenix.end2end.RebuildIndexConnectionPropsIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.493 s 
- in org.apache.phoenix.end2end.RebuildIndexConnectionPropsIT
[INFO] Running org.apache.phoenix.end2end.RegexBulkLoadToolIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 132.084 
s - in org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running org.apache.phoenix.end2end.RenewLeaseIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 25.59 s 
- in org.apache.phoenix.end2end.RenewLeaseIT
[INFO] Running org.apache.phoenix.end2end.SpillableGroupByIT
[INFO] Running org.apache.phoenix.end2end.SystemTablePermissionsIT
[INFO] Running org.apache.phoenix.end2end.StatsCollectorIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.081 s 
- in org.apache.phoenix.end2end.SpillableGroupByIT
[INFO] Running 
org.apache.phoenix.end2end.SysTableNamespaceMappedStatsCollectorIT
[INFO] Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 65.858 
s - in org.apache.phoenix.end2end.RegexBulkLoadToolIT
[INFO] Running org.apache.phoenix.end2end.TableSnapshotReadsMapReduceIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.015 s 
- in org.apache.phoenix.end2end.TableSnapshotReadsMapReduceIT
[INFO] Running org.apache.phoenix.end2end.UpdateCacheAcrossDifferentClientsIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 79.812 s 
- in 

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

2017-09-15 Thread Apache Jenkins Server
4.x-HBase-1.2 branch build status Successful

Source repository https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=shortlog;h=refs/heads/4.x-HBase-1.2

Compiled Artifacts https://builds.apache.org/job/Phoenix-4.x-HBase-1.2/lastSuccessfulBuild/artifact/

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

Changes
[mujtaba] PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use

[mujtaba] PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN

[mujtaba] PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN



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


svn commit: r1808487 [1/2] - in /phoenix: phoenix-docs/src/docsrc/help/ site/publish/ site/publish/language/ site/source/src/site/ site/source/src/site/markdown/

2017-09-15 Thread jamestaylor
Author: jamestaylor
Date: Fri Sep 15 22:10:25 2017
New Revision: 1808487

URL: http://svn.apache.org/viewvc?rev=1808487=rev
Log:
Doc patches: PHOENIX-4136 APPROXIMATE_COUNT_DISTINCT, PHOENIX-4001 CURSOR, 
PHOENIX-4137 Document IndexScrutinyTool

Added:
phoenix/site/publish/cursors.html
phoenix/site/source/src/site/markdown/cursors.md
Modified:
phoenix/phoenix-docs/src/docsrc/help/phoenix.csv
phoenix/site/publish/Phoenix-in-15-minutes-or-less.html
phoenix/site/publish/array_type.html
phoenix/site/publish/atomic_upsert.html
phoenix/site/publish/building.html
phoenix/site/publish/building_website.html
phoenix/site/publish/bulk_dataload.html
phoenix/site/publish/columnencoding.html
phoenix/site/publish/contributing.html
phoenix/site/publish/develop.html
phoenix/site/publish/download.html
phoenix/site/publish/dynamic_columns.html
phoenix/site/publish/faq.html
phoenix/site/publish/flume.html
phoenix/site/publish/hive_storage_handler.html
phoenix/site/publish/index.html
phoenix/site/publish/installation.html
phoenix/site/publish/issues.html
phoenix/site/publish/joins.html
phoenix/site/publish/kafka.html
phoenix/site/publish/language/datatypes.html
phoenix/site/publish/language/functions.html
phoenix/site/publish/language/index.html
phoenix/site/publish/mailing_list.html
phoenix/site/publish/metrics.html
phoenix/site/publish/multi-tenancy.html
phoenix/site/publish/namspace_mapping.html
phoenix/site/publish/news.html
phoenix/site/publish/paged.html
phoenix/site/publish/performance.html
phoenix/site/publish/pherf.html
phoenix/site/publish/phoenix_mr.html
phoenix/site/publish/phoenix_on_emr.html
phoenix/site/publish/phoenix_orm.html
phoenix/site/publish/phoenix_python.html
phoenix/site/publish/phoenix_spark.html
phoenix/site/publish/phoenixcon.html
phoenix/site/publish/pig_integration.html
phoenix/site/publish/recent.html
phoenix/site/publish/release.html
phoenix/site/publish/release_notes.html
phoenix/site/publish/resources.html
phoenix/site/publish/roadmap.html
phoenix/site/publish/rowtimestamp.html
phoenix/site/publish/salted.html
phoenix/site/publish/secondary_indexing.html
phoenix/site/publish/sequences.html
phoenix/site/publish/server.html
phoenix/site/publish/skip_scan.html
phoenix/site/publish/source.html
phoenix/site/publish/subqueries.html
phoenix/site/publish/team.html
phoenix/site/publish/tracing.html
phoenix/site/publish/transactions.html
phoenix/site/publish/tuning.html
phoenix/site/publish/tuning_guide.html
phoenix/site/publish/udf.html
phoenix/site/publish/update_statistics.html
phoenix/site/publish/upgrading.html
phoenix/site/publish/views.html
phoenix/site/publish/who_is_using.html
phoenix/site/source/src/site/markdown/secondary_indexing.md
phoenix/site/source/src/site/site.xml

Modified: phoenix/phoenix-docs/src/docsrc/help/phoenix.csv
URL: 
http://svn.apache.org/viewvc/phoenix/phoenix-docs/src/docsrc/help/phoenix.csv?rev=1808487=1808486=1808487=diff
==
--- phoenix/phoenix-docs/src/docsrc/help/phoenix.csv (original)
+++ phoenix/phoenix-docs/src/docsrc/help/phoenix.csv Fri Sep 15 22:10:25 2017
@@ -70,6 +70,43 @@ DELETE FROM TEST WHERE ID=123;
 DELETE FROM TEST WHERE NAME LIKE 'foo%';
 "
 
+"Commands","DECLARE CURSOR","
+DECLARE CURSOR cursorName FOR selectStatement
+","
+Creates a cursor for the select statement
+
+","
+DECLARE CURSOR TEST_CURSOR FOR SELECT * FROM TEST_TABLE
+"
+
+"Commands","OPEN CURSOR","
+OPEN CURSOR cursorName
+","
+Opens already declared cursor to perform FETCH operations
+
+","
+OPEN CURSOR TEST_CURSOR
+"
+
+"Commands","FETCH NEXT","
+FETCH NEXT [n ROWS] FROM cursorName
+","
+Retrieves next or next n rows from already opened cursor
+
+","
+FETCH NEXT FROM TEST_CURSOR
+FETCH NEXT 10 ROWS FROM TEST_CURSOR
+"
+
+"Commands","CLOSE","
+CLOSE cursorName
+","
+Closes an already open cursor
+
+","
+CLOSE TEST_CURSOR
+"
+
 "Commands","CREATE TABLE","
 CREATE TABLE [IF NOT EXISTS] tableRef
 ( columnDef [,...] [constraint] )
@@ -1381,6 +1418,18 @@ Aggregates are only allowed in select st
 COUNT(*)
 "
 
+"Functions (Aggregate)","APPROX_COUNT_DISTINCT","
+APPROX_COUNT_DISTINCT( { * | { term } } )
+","
+The approximate distinct count of all row, or of the non-null values.
+The relative error of approximation by default is less than 0.00405
+This method returns a long.
+If no rows are selected, the result is 0.
+Aggregates are only allowed in select statements.
+","
+APPROX_COUNT_DISTINCT(*)
+"
+
 "Functions (Aggregate)","MAX","
 MAX(term)
 ","

Modified: phoenix/site/publish/Phoenix-in-15-minutes-or-less.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/Phoenix-in-15-minutes-or-less.html?rev=1808487=1808486=1808487=diff

svn commit: r1808487 [2/2] - in /phoenix: phoenix-docs/src/docsrc/help/ site/publish/ site/publish/language/ site/source/src/site/ site/source/src/site/markdown/

2017-09-15 Thread jamestaylor
Modified: phoenix/site/publish/phoenixcon.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/phoenixcon.html?rev=1808487=1808486=1808487=diff
==
--- phoenix/site/publish/phoenixcon.html (original)
+++ phoenix/site/publish/phoenixcon.html Fri Sep 15 22:10:25 2017
@@ -1,7 +1,7 @@
 
 
 
 
@@ -122,8 +122,9 @@

Bulk Loading
Query Server
-   Tracing
Metrics
+   Tracing
+   Cursor



@@ -368,10 +369,13 @@
Query Server


+   Metrics
+   
+   
Tracing


-   Metrics
+   Cursor




Modified: phoenix/site/publish/pig_integration.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/pig_integration.html?rev=1808487=1808486=1808487=diff
==
--- phoenix/site/publish/pig_integration.html (original)
+++ phoenix/site/publish/pig_integration.html Fri Sep 15 22:10:25 2017
@@ -1,7 +1,7 @@
 
 
 
 
@@ -122,8 +122,9 @@

Bulk Loading
Query Server
-   Tracing
Metrics
+   Tracing
+   Cursor



@@ -418,10 +419,13 @@ DUMP cnt;
Query Server


+   Metrics
+   
+   
Tracing


-   Metrics
+   Cursor




Modified: phoenix/site/publish/recent.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/recent.html?rev=1808487=1808486=1808487=diff
==
--- phoenix/site/publish/recent.html (original)
+++ phoenix/site/publish/recent.html Fri Sep 15 22:10:25 2017
@@ -1,7 +1,7 @@
 
 
 
 
@@ -122,8 +122,9 @@

Bulk Loading
Query Server
-   Tracing
Metrics
+   Tracing
+   Cursor



@@ -391,10 +392,13 @@
 

Build failed in Jenkins: Phoenix | Master #1801

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[mujtaba] PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use

[mujtaba] PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use 
currentSCN

[mujtaba] PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN

--
[...truncated 101.93 KB...]
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.354 s 
- in org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
[INFO] Running org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.545 s 
- in org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Running org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 35.249 s 
- in org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Running org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.118 s 
- in org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Running org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 49.951 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.909 s 
- in org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.421 s 
- in org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Running org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.285 s 
- in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Tests run: 64, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 456.01 
s - in org.apache.phoenix.end2end.index.MutableIndexIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 102, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
1,090.25 s - in org.apache.phoenix.end2end.SortMergeJoinIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 88.338 s 
- in org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 47.492 s 
- in org.apache.phoenix.tx.TransactionIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 10.111 s 
- in org.apache.phoenix.util.IndexScrutinyIT
[WARNING] Tests run: 52, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
203.66 s - in org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 694.494 
s - in org.apache.phoenix.end2end.index.MutableIndexSplitForwardScanIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 700.374 
s - in org.apache.phoenix.end2end.index.MutableIndexSplitReverseScanIT
[INFO] Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 274.22 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 320, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
1,988.256 s - in org.apache.phoenix.end2end.index.IndexIT
[INFO] 
[INFO] Results:
[INFO] 
[WARNING] Tests run: 3232, Failures: 0, Errors: 0, Skipped: 5
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (ClientManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Running org.apache.phoenix.end2end.UpsertValuesIT
[INFO] Running org.apache.phoenix.end2end.DerivedTableIT
[INFO] Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 25.637 
s - in org.apache.phoenix.end2end.DerivedTableIT
[INFO] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 59.407 
s - in org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 25, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 117.978 
s - in org.apache.phoenix.end2end.UpsertValuesIT
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 93, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (HBaseManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 

Build failed in Jenkins: Phoenix | Master #1800

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[jtaylor] PHOENIX-4211 Change tephra dependency in phoenix-kafka to test

[jtaylor] PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN 
set

--
[...truncated 104.46 KB...]
[INFO] Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 250.288 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 696.03 s 
- in org.apache.phoenix.end2end.index.MutableIndexSplitForwardScanIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 702.091 
s - in org.apache.phoenix.end2end.index.MutableIndexSplitReverseScanIT
[INFO] Tests run: 320, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
2,195.409 s - in org.apache.phoenix.end2end.index.IndexIT
[INFO] 
[INFO] Results:
[INFO] 
[ERROR] Failures: 
[ERROR]   ConcurrentMutationsIT.testConcurrentDeletesAndUpsertValues:214 
Expected to find PK in data table: (6,0)
[ERROR]   ConcurrentMutationsIT.testConcurrentUpserts:262 Ran out of time
[ERROR]   Ran out of time
[INFO] 
[ERROR] Tests run: 3012, Failures: 3, Errors: 0, Skipped: 14
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (ClientManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running org.apache.phoenix.end2end.DerivedTableIT
[INFO] Running org.apache.phoenix.end2end.UpsertValuesIT
[INFO] Running org.apache.phoenix.end2end.SequenceIT
[INFO] Running org.apache.phoenix.end2end.ExtendedQueryExecIT
[INFO] Running org.apache.phoenix.end2end.FunkyNamesIT
[INFO] Running org.apache.phoenix.end2end.SequenceBulkAllocationIT
[INFO] Running org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.822 s 
- in org.apache.phoenix.end2end.FunkyNamesIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 18.613 s 
- in org.apache.phoenix.end2end.ExtendedQueryExecIT
[INFO] Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 45.728 
s - in org.apache.phoenix.end2end.DerivedTableIT
[INFO] Tests run: 56, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 70.721 
s - in org.apache.phoenix.end2end.SequenceBulkAllocationIT
[INFO] Tests run: 55, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 76.124 
s - in org.apache.phoenix.end2end.SequenceIT
[INFO] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 86.335 
s - in org.apache.phoenix.end2end.VariableLengthPKIT
[INFO] Tests run: 25, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 144.966 
s - in org.apache.phoenix.end2end.UpsertValuesIT
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 211, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (HBaseManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test 
(NeedTheirOwnClusterTests) @ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 68.886 s 
- in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.165 s 
- in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 35.224 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.42 s - 
in org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Running org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.823 s 
- in org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.DropSchemaIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 23.758 s 
- in org.apache.phoenix.end2end.DropSchemaIT
[INFO] Running org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running 

Jenkins build is back to normal : Phoenix-4.x-HBase-1.2 #167

2017-09-15 Thread Apache Jenkins Server
See 




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

2017-09-15 Thread Apache Jenkins Server
See 


Changes:

[jtaylor] PHOENIX-4211 Change tephra dependency in phoenix-kafka to test

[jtaylor] PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN 
set

--
[...truncated 106.76 KB...]
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 38.809 s 
- in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.582 s 
- in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[WARNING] Corrupted stdin stream in forked JVM 3. See the dump file 

[INFO] Running org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.788 s 
- in org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.574 s 
- in org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 22.645 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running org.apache.phoenix.end2end.DropSchemaIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 11.053 s 
- in org.apache.phoenix.end2end.DropSchemaIT
[INFO] Running org.apache.phoenix.end2end.IndexExtendedIT
[INFO] Running org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running org.apache.phoenix.end2end.IndexToolForPartialBuildIT
[INFO] Running org.apache.phoenix.end2end.IndexScrutinyToolIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 79.55 s 
- in org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 30.814 s 
- in org.apache.phoenix.end2end.IndexToolForPartialBuildIT
[INFO] Running 
org.apache.phoenix.end2end.IndexToolForPartialBuildWithNamespaceEnabledIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 34.901 s 
- in org.apache.phoenix.end2end.IndexToolForPartialBuildWithNamespaceEnabledIT
[INFO] Running org.apache.phoenix.end2end.QueryTimeoutIT
[INFO] Running org.apache.phoenix.end2end.QueryWithLimitIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.578 s 
- in org.apache.phoenix.end2end.QueryWithLimitIT
[INFO] Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 112.182 
s - in org.apache.phoenix.end2end.IndexScrutinyToolIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 22.797 s 
- in org.apache.phoenix.end2end.QueryTimeoutIT
[INFO] Running org.apache.phoenix.end2end.RebuildIndexConnectionPropsIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.921 s 
- in org.apache.phoenix.end2end.RebuildIndexConnectionPropsIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 135.341 
s - in org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running org.apache.phoenix.end2end.RegexBulkLoadToolIT
[INFO] Running org.apache.phoenix.end2end.RenewLeaseIT
[INFO] Running org.apache.phoenix.end2end.StatsCollectorIT
[INFO] Running org.apache.phoenix.end2end.SpillableGroupByIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.115 s 
- in org.apache.phoenix.end2end.SpillableGroupByIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 26.471 s 
- in org.apache.phoenix.end2end.RenewLeaseIT
[INFO] Running 
org.apache.phoenix.end2end.SysTableNamespaceMappedStatsCollectorIT
[INFO] Running org.apache.phoenix.end2end.SystemTablePermissionsIT
[INFO] Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 73.133 
s - in org.apache.phoenix.end2end.RegexBulkLoadToolIT
[INFO] Running org.apache.phoenix.end2end.TableSnapshotReadsMapReduceIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 17.236 s 
- in org.apache.phoenix.end2end.TableSnapshotReadsMapReduceIT
[INFO] Running org.apache.phoenix.end2end.UpdateCacheAcrossDifferentClientsIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 82.629 s 
- in org.apache.phoenix.end2end.SystemTablePermissionsIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 28.059 s 
- in org.apache.phoenix.end2end.UpdateCacheAcrossDifferentClientsIT
[INFO] Running org.apache.phoenix.end2end.UserDefinedFunctionsIT
[INFO] Running org.apache.phoenix.end2end.index.ImmutableIndexIT
[INFO] Running org.apache.phoenix.end2end.index.LocalIndexIT
[INFO] Tests run: 14, Failures: 0, 

phoenix git commit: PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/master a4f6c2c1a -> c06ef877e


PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN


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

Branch: refs/heads/master
Commit: c06ef877efa2c55de3430c8289ebad63e8bebc93
Parents: a4f6c2c
Author: Mujtaba 
Authored: Fri Sep 15 10:59:49 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:59:49 2017 -0700

--
 .../org/apache/phoenix/end2end/SequenceIT.java  | 896 ++-
 1 file changed, 461 insertions(+), 435 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c06ef877/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
index 10f465f..7a06bcd 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
@@ -35,6 +35,7 @@ import java.util.Map;
 import java.util.Properties;
 
 import org.apache.phoenix.exception.SQLExceptionCode;
+import org.apache.phoenix.jdbc.PhoenixDatabaseMetaData;
 import org.apache.phoenix.jdbc.PhoenixStatement;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.schema.SchemaNotFoundException;
@@ -44,31 +45,41 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.apache.phoenix.util.SequenceUtil;
 import org.junit.After;
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 
-public class SequenceIT extends BaseClientManagedTimeIT {
-private static final String NEXT_VAL_SQL = "SELECT NEXT VALUE FOR foo.bar 
FROM \"SYSTEM\".\"SEQUENCE\"";
-private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s FROM \"SYSTEM\".\"SEQUENCE\"";
+public class SequenceIT extends ParallelStatsDisabledIT {
+private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s";
 private static final long BATCH_SIZE = 3;

 private Connection conn;
 
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
+
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() throws Exception {
 // close any open connection between tests, so that connections are 
not leaked
@@ -79,20 +90,21 @@ public class SequenceIT extends BaseClientManagedTimeIT {
 
@Test
public void testSystemTable() throws Exception {
-   nextConnection();
+   conn.createStatement().execute("CREATE SEQUENCE " + 
generateNameWithSchema());
String query = "SELECT sequence_schema, sequence_name, 
current_value, increment_by FROM \"SYSTEM\".\"SEQUENCE\"";
ResultSet rs = conn.prepareStatement(query).executeQuery();
-   assertFalse(rs.next());
+   assertTrue(rs.next());
}
 
@Test
public void testDuplicateSequences() throws Exception {
-nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE alpha.beta 
START WITH 2 INCREMENT BY 4\n");
+String sequenceName = generateNameWithSchema();
+
+
+   conn.createStatement().execute("CREATE SEQUENCE " + 
sequenceName + " START WITH 2 INCREMENT BY 4\n");
 
try {
-   nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE 
alpha.beta START WITH 2 INCREMENT BY 4\n");
+   

phoenix git commit: PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 e45f1b274 -> 4348212a3


PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN


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

Branch: refs/heads/4.x-HBase-1.1
Commit: 4348212a3b0fce03d4820cc415ff1b1e09db3de1
Parents: e45f1b2
Author: Mujtaba 
Authored: Fri Sep 15 10:59:19 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:59:19 2017 -0700

--
 .../org/apache/phoenix/end2end/SequenceIT.java  | 896 ++-
 1 file changed, 461 insertions(+), 435 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/4348212a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
index 10f465f..7a06bcd 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
@@ -35,6 +35,7 @@ import java.util.Map;
 import java.util.Properties;
 
 import org.apache.phoenix.exception.SQLExceptionCode;
+import org.apache.phoenix.jdbc.PhoenixDatabaseMetaData;
 import org.apache.phoenix.jdbc.PhoenixStatement;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.schema.SchemaNotFoundException;
@@ -44,31 +45,41 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.apache.phoenix.util.SequenceUtil;
 import org.junit.After;
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 
-public class SequenceIT extends BaseClientManagedTimeIT {
-private static final String NEXT_VAL_SQL = "SELECT NEXT VALUE FOR foo.bar 
FROM \"SYSTEM\".\"SEQUENCE\"";
-private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s FROM \"SYSTEM\".\"SEQUENCE\"";
+public class SequenceIT extends ParallelStatsDisabledIT {
+private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s";
 private static final long BATCH_SIZE = 3;

 private Connection conn;
 
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
+
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() throws Exception {
 // close any open connection between tests, so that connections are 
not leaked
@@ -79,20 +90,21 @@ public class SequenceIT extends BaseClientManagedTimeIT {
 
@Test
public void testSystemTable() throws Exception {
-   nextConnection();
+   conn.createStatement().execute("CREATE SEQUENCE " + 
generateNameWithSchema());
String query = "SELECT sequence_schema, sequence_name, 
current_value, increment_by FROM \"SYSTEM\".\"SEQUENCE\"";
ResultSet rs = conn.prepareStatement(query).executeQuery();
-   assertFalse(rs.next());
+   assertTrue(rs.next());
}
 
@Test
public void testDuplicateSequences() throws Exception {
-nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE alpha.beta 
START WITH 2 INCREMENT BY 4\n");
+String sequenceName = generateNameWithSchema();
+
+
+   conn.createStatement().execute("CREATE SEQUENCE " + 
sequenceName + " START WITH 2 INCREMENT BY 4\n");
 
try {
-   nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE 
alpha.beta START WITH 2 INCREMENT BY 4\n");
+ 

phoenix git commit: PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.2 78666ee40 -> b37ccb52d


PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN


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

Branch: refs/heads/4.x-HBase-1.2
Commit: b37ccb52d66cf9c5831439ee3b5d7b846c31a502
Parents: 78666ee
Author: Mujtaba 
Authored: Fri Sep 15 10:59:32 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:59:32 2017 -0700

--
 .../org/apache/phoenix/end2end/SequenceIT.java  | 896 ++-
 1 file changed, 461 insertions(+), 435 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/b37ccb52/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
index 10f465f..7a06bcd 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
@@ -35,6 +35,7 @@ import java.util.Map;
 import java.util.Properties;
 
 import org.apache.phoenix.exception.SQLExceptionCode;
+import org.apache.phoenix.jdbc.PhoenixDatabaseMetaData;
 import org.apache.phoenix.jdbc.PhoenixStatement;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.schema.SchemaNotFoundException;
@@ -44,31 +45,41 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.apache.phoenix.util.SequenceUtil;
 import org.junit.After;
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 
-public class SequenceIT extends BaseClientManagedTimeIT {
-private static final String NEXT_VAL_SQL = "SELECT NEXT VALUE FOR foo.bar 
FROM \"SYSTEM\".\"SEQUENCE\"";
-private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s FROM \"SYSTEM\".\"SEQUENCE\"";
+public class SequenceIT extends ParallelStatsDisabledIT {
+private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s";
 private static final long BATCH_SIZE = 3;

 private Connection conn;
 
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
+
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() throws Exception {
 // close any open connection between tests, so that connections are 
not leaked
@@ -79,20 +90,21 @@ public class SequenceIT extends BaseClientManagedTimeIT {
 
@Test
public void testSystemTable() throws Exception {
-   nextConnection();
+   conn.createStatement().execute("CREATE SEQUENCE " + 
generateNameWithSchema());
String query = "SELECT sequence_schema, sequence_name, 
current_value, increment_by FROM \"SYSTEM\".\"SEQUENCE\"";
ResultSet rs = conn.prepareStatement(query).executeQuery();
-   assertFalse(rs.next());
+   assertTrue(rs.next());
}
 
@Test
public void testDuplicateSequences() throws Exception {
-nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE alpha.beta 
START WITH 2 INCREMENT BY 4\n");
+String sequenceName = generateNameWithSchema();
+
+
+   conn.createStatement().execute("CREATE SEQUENCE " + 
sequenceName + " START WITH 2 INCREMENT BY 4\n");
 
try {
-   nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE 
alpha.beta START WITH 2 INCREMENT BY 4\n");
+ 

phoenix git commit: PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 75901ed0f -> b46b735f0


PHOENIX-4199 Modify SequenceIT.java to not use CurrentSCN


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

Branch: refs/heads/4.x-HBase-0.98
Commit: b46b735f0b997c4640baade689bd0132327ba597
Parents: 75901ed
Author: Mujtaba 
Authored: Fri Sep 15 10:58:49 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:58:49 2017 -0700

--
 .../org/apache/phoenix/end2end/SequenceIT.java  | 896 ++-
 1 file changed, 461 insertions(+), 435 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/b46b735f/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
index 10f465f..7a06bcd 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceIT.java
@@ -35,6 +35,7 @@ import java.util.Map;
 import java.util.Properties;
 
 import org.apache.phoenix.exception.SQLExceptionCode;
+import org.apache.phoenix.jdbc.PhoenixDatabaseMetaData;
 import org.apache.phoenix.jdbc.PhoenixStatement;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.schema.SchemaNotFoundException;
@@ -44,31 +45,41 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.apache.phoenix.util.SequenceUtil;
 import org.junit.After;
 import org.junit.Assert;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 
-public class SequenceIT extends BaseClientManagedTimeIT {
-private static final String NEXT_VAL_SQL = "SELECT NEXT VALUE FOR foo.bar 
FROM \"SYSTEM\".\"SEQUENCE\"";
-private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s FROM \"SYSTEM\".\"SEQUENCE\"";
+public class SequenceIT extends ParallelStatsDisabledIT {
+private static final String SELECT_NEXT_VALUE_SQL = "SELECT NEXT VALUE FOR 
%s";
 private static final long BATCH_SIZE = 3;

 private Connection conn;
 
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
+
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() throws Exception {
 // close any open connection between tests, so that connections are 
not leaked
@@ -79,20 +90,21 @@ public class SequenceIT extends BaseClientManagedTimeIT {
 
@Test
public void testSystemTable() throws Exception {
-   nextConnection();
+   conn.createStatement().execute("CREATE SEQUENCE " + 
generateNameWithSchema());
String query = "SELECT sequence_schema, sequence_name, 
current_value, increment_by FROM \"SYSTEM\".\"SEQUENCE\"";
ResultSet rs = conn.prepareStatement(query).executeQuery();
-   assertFalse(rs.next());
+   assertTrue(rs.next());
}
 
@Test
public void testDuplicateSequences() throws Exception {
-nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE alpha.beta 
START WITH 2 INCREMENT BY 4\n");
+String sequenceName = generateNameWithSchema();
+
+
+   conn.createStatement().execute("CREATE SEQUENCE " + 
sequenceName + " START WITH 2 INCREMENT BY 4\n");
 
try {
-   nextConnection();
-   conn.createStatement().execute("CREATE SEQUENCE 
alpha.beta START WITH 2 INCREMENT BY 4\n");
+   

phoenix git commit: PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/master b2153ef52 -> a4f6c2c1a


PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN


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

Branch: refs/heads/master
Commit: a4f6c2c1a2cbad426f22e6112be08d14397288c5
Parents: b2153ef
Author: Mujtaba 
Authored: Fri Sep 15 10:55:11 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:55:11 2017 -0700

--
 .../end2end/SequenceBulkAllocationIT.java   | 538 +--
 1 file changed, 258 insertions(+), 280 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/a4f6c2c1/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
index c057f49..2c2df73 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
@@ -39,7 +39,9 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.junit.After;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -47,6 +49,7 @@ import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 /**
  * Suite of integration tests that validate that Bulk Allocation of Sequence 
values
@@ -57,19 +60,19 @@ import com.google.common.collect.Lists;
  * 
  */
 @RunWith(Parameterized.class)
-public class SequenceBulkAllocationIT extends BaseClientManagedTimeIT {
+public class SequenceBulkAllocationIT extends ParallelStatsDisabledIT {
 
 private static final long BATCH_SIZE = 3;
 private static final String SELECT_NEXT_VALUE_SQL =
-"SELECT NEXT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT NEXT VALUE FOR %s";
 private static final String SELECT_CURRENT_VALUE_SQL =
-"SELECT CURRENT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT CURRENT VALUE FOR %s";
 private static final String CREATE_SEQUENCE_NO_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s CACHE %s";
 private static final String CREATE_SEQUENCE_WITH_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CACHE %s";
 private static final String 
CREATE_SEQUENCE_WITH_MIN_MAX_AND_CYCLE_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CYCLE CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CYCLE CACHE %s";
 
 
 private Connection conn;
@@ -78,16 +81,29 @@ public class SequenceBulkAllocationIT extends 
BaseClientManagedTimeIT {
 public SequenceBulkAllocationIT(String tenantId) {
 this.tenantId = tenantId;
 }
+
+@Parameters(name="SequenceBulkAllocationIT_tenantId={0}") // name is used 
by failsafe as file name in reports
+public static Object[] data() {
+return new Object[] {null, "tenant1"};
+}
+
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
 
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() throws 

phoenix git commit: PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.2 13bb73031 -> 78666ee40


PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN


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

Branch: refs/heads/4.x-HBase-1.2
Commit: 78666ee40964af5054a1eba7dc53997e82946b2a
Parents: 13bb730
Author: Mujtaba 
Authored: Fri Sep 15 10:54:51 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:54:51 2017 -0700

--
 .../end2end/SequenceBulkAllocationIT.java   | 538 +--
 1 file changed, 258 insertions(+), 280 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/78666ee4/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
index c057f49..2c2df73 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
@@ -39,7 +39,9 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.junit.After;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -47,6 +49,7 @@ import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 /**
  * Suite of integration tests that validate that Bulk Allocation of Sequence 
values
@@ -57,19 +60,19 @@ import com.google.common.collect.Lists;
  * 
  */
 @RunWith(Parameterized.class)
-public class SequenceBulkAllocationIT extends BaseClientManagedTimeIT {
+public class SequenceBulkAllocationIT extends ParallelStatsDisabledIT {
 
 private static final long BATCH_SIZE = 3;
 private static final String SELECT_NEXT_VALUE_SQL =
-"SELECT NEXT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT NEXT VALUE FOR %s";
 private static final String SELECT_CURRENT_VALUE_SQL =
-"SELECT CURRENT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT CURRENT VALUE FOR %s";
 private static final String CREATE_SEQUENCE_NO_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s CACHE %s";
 private static final String CREATE_SEQUENCE_WITH_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CACHE %s";
 private static final String 
CREATE_SEQUENCE_WITH_MIN_MAX_AND_CYCLE_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CYCLE CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CYCLE CACHE %s";
 
 
 private Connection conn;
@@ -78,16 +81,29 @@ public class SequenceBulkAllocationIT extends 
BaseClientManagedTimeIT {
 public SequenceBulkAllocationIT(String tenantId) {
 this.tenantId = tenantId;
 }
+
+@Parameters(name="SequenceBulkAllocationIT_tenantId={0}") // name is used 
by failsafe as file name in reports
+public static Object[] data() {
+return new Object[] {null, "tenant1"};
+}
+
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
 
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() 

phoenix git commit: PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 c629d7989 -> e45f1b274


PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN


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

Branch: refs/heads/4.x-HBase-1.1
Commit: e45f1b274c1e79160b0e23a3d56409abe1a06094
Parents: c629d79
Author: Mujtaba 
Authored: Fri Sep 15 10:54:36 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:54:36 2017 -0700

--
 .../end2end/SequenceBulkAllocationIT.java   | 538 +--
 1 file changed, 258 insertions(+), 280 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/e45f1b27/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
index c057f49..2c2df73 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
@@ -39,7 +39,9 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.junit.After;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -47,6 +49,7 @@ import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 /**
  * Suite of integration tests that validate that Bulk Allocation of Sequence 
values
@@ -57,19 +60,19 @@ import com.google.common.collect.Lists;
  * 
  */
 @RunWith(Parameterized.class)
-public class SequenceBulkAllocationIT extends BaseClientManagedTimeIT {
+public class SequenceBulkAllocationIT extends ParallelStatsDisabledIT {
 
 private static final long BATCH_SIZE = 3;
 private static final String SELECT_NEXT_VALUE_SQL =
-"SELECT NEXT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT NEXT VALUE FOR %s";
 private static final String SELECT_CURRENT_VALUE_SQL =
-"SELECT CURRENT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT CURRENT VALUE FOR %s";
 private static final String CREATE_SEQUENCE_NO_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s CACHE %s";
 private static final String CREATE_SEQUENCE_WITH_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CACHE %s";
 private static final String 
CREATE_SEQUENCE_WITH_MIN_MAX_AND_CYCLE_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CYCLE CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CYCLE CACHE %s";
 
 
 private Connection conn;
@@ -78,16 +81,29 @@ public class SequenceBulkAllocationIT extends 
BaseClientManagedTimeIT {
 public SequenceBulkAllocationIT(String tenantId) {
 this.tenantId = tenantId;
 }
+
+@Parameters(name="SequenceBulkAllocationIT_tenantId={0}") // name is used 
by failsafe as file name in reports
+public static Object[] data() {
+return new Object[] {null, "tenant1"};
+}
+
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
 
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void tearDown() 

phoenix git commit: PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 149a9b931 -> 75901ed0f


PHOENIX-4204 Modify SequenceBulkAllocationIT.java to not use currentSCN


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 75901ed0f9071da64e28142799f079d67975f386
Parents: 149a9b9
Author: Mujtaba 
Authored: Fri Sep 15 10:46:47 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:46:47 2017 -0700

--
 .../end2end/SequenceBulkAllocationIT.java   | 538 +--
 1 file changed, 258 insertions(+), 280 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/75901ed0/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
index c057f49..2c2df73 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/SequenceBulkAllocationIT.java
@@ -39,7 +39,9 @@ import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
+import org.apache.phoenix.util.SchemaUtil;
 import org.junit.After;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -47,6 +49,7 @@ import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameters;
 
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 
 /**
  * Suite of integration tests that validate that Bulk Allocation of Sequence 
values
@@ -57,19 +60,19 @@ import com.google.common.collect.Lists;
  * 
  */
 @RunWith(Parameterized.class)
-public class SequenceBulkAllocationIT extends BaseClientManagedTimeIT {
+public class SequenceBulkAllocationIT extends ParallelStatsDisabledIT {
 
 private static final long BATCH_SIZE = 3;
 private static final String SELECT_NEXT_VALUE_SQL =
-"SELECT NEXT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT NEXT VALUE FOR %s";
 private static final String SELECT_CURRENT_VALUE_SQL =
-"SELECT CURRENT VALUE FOR %s FROM \"SYSTEM\".\"SEQUENCE\" LIMIT 1";
+"SELECT CURRENT VALUE FOR %s";
 private static final String CREATE_SEQUENCE_NO_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s CACHE %s";
 private static final String CREATE_SEQUENCE_WITH_MIN_MAX_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CACHE %s";
 private static final String 
CREATE_SEQUENCE_WITH_MIN_MAX_AND_CYCLE_TEMPLATE =
-"CREATE SEQUENCE bulkalloc.alpha START WITH %s INCREMENT BY %s 
MINVALUE %s MAXVALUE %s CYCLE CACHE %s";
+"CREATE SEQUENCE %s START WITH %s INCREMENT BY %s MINVALUE %s 
MAXVALUE %s CYCLE CACHE %s";
 
 
 private Connection conn;
@@ -78,16 +81,29 @@ public class SequenceBulkAllocationIT extends 
BaseClientManagedTimeIT {
 public SequenceBulkAllocationIT(String tenantId) {
 this.tenantId = tenantId;
 }
+
+@Parameters(name="SequenceBulkAllocationIT_tenantId={0}") // name is used 
by failsafe as file name in reports
+public static Object[] data() {
+return new Object[] {null, "tenant1"};
+}
+
+private static String generateNameWithSchema() {
+   return SchemaUtil.getTableName(generateUniqueName(), 
generateUniqueName());
+}
 
 @BeforeClass
-@Shadower(classBeingShadowed = BaseClientManagedTimeIT.class)
+@Shadower(classBeingShadowed = ParallelStatsDisabledIT.class)
 public static void doSetup() throws Exception {
-Map props = getDefaultProps();
-// Must update config before starting server
+Map props = Maps.newHashMap();
 props.put(QueryServices.SEQUENCE_CACHE_SIZE_ATTRIB, 
Long.toString(BATCH_SIZE));
 setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
 }
 
+@Before
+public void init() throws Exception {
+   createConnection();
+}
+
 @After
 public void 

phoenix git commit: PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.2 7fabb75ba -> 13bb73031


PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN


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

Branch: refs/heads/4.x-HBase-1.2
Commit: 13bb730317b7d75498a46b8dfb4ab2d4c4b09b5a
Parents: 7fabb75
Author: Mujtaba 
Authored: Fri Sep 15 10:39:50 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:39:50 2017 -0700

--
 .../phoenix/end2end/ExtendedQueryExecIT.java| 30 +
 .../apache/phoenix/end2end/FunkyNamesIT.java| 47 +---
 2 files changed, 30 insertions(+), 47 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/13bb7303/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
index f46b3e4..f894725 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
@@ -22,7 +22,6 @@ import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 
 import java.sql.Connection;
 import java.sql.Date;
@@ -32,33 +31,28 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
-
-
 /**
  * 
  * Extended tests for Phoenix JDBC implementation
  * 
  */
 
-public class ExtendedQueryExecIT extends BaseClientManagedTimeIT {
+public class ExtendedQueryExecIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),date, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts+1));
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setString(1, "1970-1-1 12:00:00");
 ResultSet rs = statement.executeQuery();
@@ -73,14 +67,13 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
 justification="Test code.")
 @Test
 public void testTypeMismatchToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),null, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),null, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setDate(1, new Date(2));
 statement.executeQuery();
@@ -99,17 +92,15 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
  */
 @Test
 public void testDateFunctions() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = 

phoenix git commit: PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/master 6c3bcb6a9 -> b2153ef52


PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN


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

Branch: refs/heads/master
Commit: b2153ef52a8de60501fad964062b7f7f9b86654a
Parents: 6c3bcb6
Author: Mujtaba 
Authored: Fri Sep 15 10:38:53 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:38:53 2017 -0700

--
 .../phoenix/end2end/ExtendedQueryExecIT.java| 30 +
 .../apache/phoenix/end2end/FunkyNamesIT.java| 47 +---
 2 files changed, 30 insertions(+), 47 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/b2153ef5/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
index f46b3e4..f894725 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
@@ -22,7 +22,6 @@ import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 
 import java.sql.Connection;
 import java.sql.Date;
@@ -32,33 +31,28 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
-
-
 /**
  * 
  * Extended tests for Phoenix JDBC implementation
  * 
  */
 
-public class ExtendedQueryExecIT extends BaseClientManagedTimeIT {
+public class ExtendedQueryExecIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),date, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts+1));
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setString(1, "1970-1-1 12:00:00");
 ResultSet rs = statement.executeQuery();
@@ -73,14 +67,13 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
 justification="Test code.")
 @Test
 public void testTypeMismatchToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),null, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),null, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setDate(1, new Date(2));
 statement.executeQuery();
@@ -99,17 +92,15 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
  */
 @Test
 public void testDateFunctions() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = initATableValues(null, 

phoenix git commit: PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 f2e137007 -> c629d7989


PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN


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

Branch: refs/heads/4.x-HBase-1.1
Commit: c629d7989eebbd11cb52fef42c77dc8646b7250c
Parents: f2e1370
Author: Mujtaba 
Authored: Fri Sep 15 10:39:37 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:39:37 2017 -0700

--
 .../phoenix/end2end/ExtendedQueryExecIT.java| 30 +
 .../apache/phoenix/end2end/FunkyNamesIT.java| 47 +---
 2 files changed, 30 insertions(+), 47 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c629d798/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
index f46b3e4..f894725 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
@@ -22,7 +22,6 @@ import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 
 import java.sql.Connection;
 import java.sql.Date;
@@ -32,33 +31,28 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
-
-
 /**
  * 
  * Extended tests for Phoenix JDBC implementation
  * 
  */
 
-public class ExtendedQueryExecIT extends BaseClientManagedTimeIT {
+public class ExtendedQueryExecIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),date, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts+1));
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setString(1, "1970-1-1 12:00:00");
 ResultSet rs = statement.executeQuery();
@@ -73,14 +67,13 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
 justification="Test code.")
 @Test
 public void testTypeMismatchToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),null, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),null, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setDate(1, new Date(2));
 statement.executeQuery();
@@ -99,17 +92,15 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
  */
 @Test
 public void testDateFunctions() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = 

phoenix git commit: PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN

2017-09-15 Thread mujtaba
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 083a32830 -> 149a9b931


PHOENIX-4213 Modify ExtendedQueryExecIT and FunkyNamesIT to not use currentSCN


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 149a9b931f2e8b4ff981f62d74418b378b741f50
Parents: 083a328
Author: Mujtaba 
Authored: Fri Sep 15 10:38:25 2017 -0700
Committer: Mujtaba 
Committed: Fri Sep 15 10:38:25 2017 -0700

--
 .../phoenix/end2end/ExtendedQueryExecIT.java| 30 +
 .../apache/phoenix/end2end/FunkyNamesIT.java| 47 +---
 2 files changed, 30 insertions(+), 47 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/149a9b93/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
index f46b3e4..f894725 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ExtendedQueryExecIT.java
@@ -22,7 +22,6 @@ import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
-import static org.apache.phoenix.util.TestUtil.ATABLE_NAME;
 
 import java.sql.Connection;
 import java.sql.Date;
@@ -32,33 +31,28 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.Properties;
 
-import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
-
-
 /**
  * 
  * Extended tests for Phoenix JDBC implementation
  * 
  */
 
-public class ExtendedQueryExecIT extends BaseClientManagedTimeIT {
+public class ExtendedQueryExecIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),date, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, 
Long.toString(ts+1));
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setString(1, "1970-1-1 12:00:00");
 ResultSet rs = statement.executeQuery();
@@ -73,14 +67,13 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
 justification="Test code.")
 @Test
 public void testTypeMismatchToDateFunctionBind() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),null, ts, getUrl(), null);
+String tableName = initATableValues(null, tenantId, 
getDefaultSplits(tenantId),null, null, getUrl(), null);
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
-String query = "SELECT a_date FROM atable WHERE organization_id='" 
+ tenantId + "' and a_date < TO_DATE(?)";
+String query = "SELECT a_date FROM " + tableName + " WHERE 
organization_id='" + tenantId + "' and a_date < TO_DATE(?)";
 PreparedStatement statement = conn.prepareStatement(query);
 statement.setDate(1, new Date(2));
 statement.executeQuery();
@@ -99,17 +92,15 @@ public class ExtendedQueryExecIT extends 
BaseClientManagedTimeIT {
  */
 @Test
 public void testDateFunctions() throws Exception {
-long ts = nextTimestamp();
 Date date = new Date(1);
 String tenantId = getOrganizationId();
 
-initATableValues(ATABLE_NAME, tenantId, 
getDefaultSplits(tenantId),date, ts, getUrl(), null);
+String tableName = 

phoenix git commit: PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like other poms

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 6eb2ceea3 -> 083a32830


PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like 
other poms


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 083a32830673e737281bedc8dfe0bb2c8939b6bf
Parents: 6eb2cee
Author: James Taylor 
Authored: Fri Sep 15 10:33:37 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:33:37 2017 -0700

--
 phoenix-kafka/pom.xml | 6 --
 1 file changed, 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/083a3283/phoenix-kafka/pom.xml
--
diff --git a/phoenix-kafka/pom.xml b/phoenix-kafka/pom.xml
index c07b080..c361d3d 100644
--- a/phoenix-kafka/pom.xml
+++ b/phoenix-kafka/pom.xml
@@ -50,12 +50,6 @@

 

-   
-   org.apache.tephra
-   tephra-core
-   test-jar
-   test
-   


org.antlr



[2/2] phoenix git commit: PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan Wang)

2017-09-15 Thread jamestaylor
PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan 
Wang)


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

Branch: refs/heads/4.x-HBase-1.2
Commit: 7fabb75ba8d1c1f91bd5262d083df93606305a7e
Parents: 7e789c6
Author: James Taylor 
Authored: Fri Sep 15 10:21:42 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:29:58 2017 -0700

--
 .../apache/phoenix/end2end/DistinctCountIT.java | 102 ---
 1 file changed, 40 insertions(+), 62 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/7fabb75b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
index a7482cb..34ce4f1 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
@@ -45,26 +45,22 @@ import java.sql.ResultSet;
 import java.sql.Types;
 import java.util.Properties;
 
-import org.apache.phoenix.schema.TableAlreadyExistsException;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
 
-public class DistinctCountIT extends BaseClientManagedTimeIT {
+public class DistinctCountIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testDistinctCountOnColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
-
-String query = "SELECT count(DISTINCT A_STRING) FROM aTable";
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
+String query = "SELECT count(DISTINCT A_STRING) FROM "+tableName;
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
-Connection conn = DriverManager.getConnection(getUrl(), props);
+Connection conn = DriverManager.getConnection(getUrl(),props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
 ResultSet rs = statement.executeQuery();
@@ -78,15 +74,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountOnRKColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM aTable";
+String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM 
"+tableName;
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
@@ -101,15 +95,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountWithGroupBy() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM aTable 
group by A_STRING";
+String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM 
"+tableName+" group by A_STRING";
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 

[1/2] phoenix git commit: PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like other poms

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 7988111db -> f2e137007


PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like 
other poms


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

Branch: refs/heads/4.x-HBase-1.1
Commit: 23799259015526ccab1f5143e7a0560ebdf49ffe
Parents: 7988111
Author: James Taylor 
Authored: Thu Sep 14 09:55:17 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:27:23 2017 -0700

--
 phoenix-kafka/pom.xml | 26 ++
 1 file changed, 6 insertions(+), 20 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/23799259/phoenix-kafka/pom.xml
--
diff --git a/phoenix-kafka/pom.xml b/phoenix-kafka/pom.xml
index e2656b5..1fa695b 100644
--- a/phoenix-kafka/pom.xml
+++ b/phoenix-kafka/pom.xml
@@ -50,26 +50,6 @@

 

-   
-   
-   org.apache.tephra
-   tephra-api
-   
-   
-   org.apache.tephra
-   tephra-core
-   
-   
-   org.apache.tephra
-   tephra-core
-   test-jar
-   test
-   
-   
-   org.apache.tephra
-   tephra-hbase-compat-1.1
-   
-


org.antlr
@@ -338,6 +318,12 @@
org.apache.flume
flume-ng-core

+
+  org.apache.tephra
+  tephra-core
+  test-jar
+  test
+

 




[2/2] phoenix git commit: PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan Wang)

2017-09-15 Thread jamestaylor
PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan 
Wang)


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

Branch: refs/heads/4.x-HBase-1.1
Commit: f2e13700795f4e9441e042c0cb5a460045130324
Parents: 2379925
Author: James Taylor 
Authored: Fri Sep 15 10:21:42 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:28:15 2017 -0700

--
 .../apache/phoenix/end2end/DistinctCountIT.java | 102 ---
 1 file changed, 40 insertions(+), 62 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/f2e13700/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
index a7482cb..34ce4f1 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
@@ -45,26 +45,22 @@ import java.sql.ResultSet;
 import java.sql.Types;
 import java.util.Properties;
 
-import org.apache.phoenix.schema.TableAlreadyExistsException;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
 
-public class DistinctCountIT extends BaseClientManagedTimeIT {
+public class DistinctCountIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testDistinctCountOnColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
-
-String query = "SELECT count(DISTINCT A_STRING) FROM aTable";
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
+String query = "SELECT count(DISTINCT A_STRING) FROM "+tableName;
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
-Connection conn = DriverManager.getConnection(getUrl(), props);
+Connection conn = DriverManager.getConnection(getUrl(),props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
 ResultSet rs = statement.executeQuery();
@@ -78,15 +74,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountOnRKColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM aTable";
+String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM 
"+tableName;
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
@@ -101,15 +95,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountWithGroupBy() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM aTable 
group by A_STRING";
+String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM 
"+tableName+" group by A_STRING";
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 

[1/2] phoenix git commit: PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like other poms

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 580b035f0 -> 6eb2ceea3


PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like 
other poms


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 70a19d12db4b944b1a6e09a6b48903511865b6de
Parents: 580b035
Author: James Taylor 
Authored: Thu Sep 14 09:55:17 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:25:27 2017 -0700

--
 phoenix-kafka/pom.xml | 20 ++--
 1 file changed, 6 insertions(+), 14 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/70a19d12/phoenix-kafka/pom.xml
--
diff --git a/phoenix-kafka/pom.xml b/phoenix-kafka/pom.xml
index 27225aa..c07b080 100644
--- a/phoenix-kafka/pom.xml
+++ b/phoenix-kafka/pom.xml
@@ -50,26 +50,12 @@

 

-   
-   
-   org.apache.tephra
-   tephra-api
-   
-   
-   org.apache.tephra
-   tephra-core
-   

org.apache.tephra
tephra-core
test-jar
test

-   
-   org.apache.tephra
-   tephra-hbase-compat-0.98
-   
-


org.antlr
@@ -311,6 +297,12 @@
org.apache.flume
flume-ng-core

+
+  org.apache.tephra
+  tephra-core
+  test-jar
+  test
+

 




[2/2] phoenix git commit: PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan Wang)

2017-09-15 Thread jamestaylor
PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan 
Wang)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 6eb2ceea312e72acdd8a4440ce549140023e4157
Parents: 70a19d1
Author: James Taylor 
Authored: Fri Sep 15 10:21:42 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:25:45 2017 -0700

--
 .../apache/phoenix/end2end/DistinctCountIT.java | 102 ---
 1 file changed, 40 insertions(+), 62 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/6eb2ceea/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
index a7482cb..34ce4f1 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
@@ -45,26 +45,22 @@ import java.sql.ResultSet;
 import java.sql.Types;
 import java.util.Properties;
 
-import org.apache.phoenix.schema.TableAlreadyExistsException;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
 
-public class DistinctCountIT extends BaseClientManagedTimeIT {
+public class DistinctCountIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testDistinctCountOnColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
-
-String query = "SELECT count(DISTINCT A_STRING) FROM aTable";
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
+String query = "SELECT count(DISTINCT A_STRING) FROM "+tableName;
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
-Connection conn = DriverManager.getConnection(getUrl(), props);
+Connection conn = DriverManager.getConnection(getUrl(),props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
 ResultSet rs = statement.executeQuery();
@@ -78,15 +74,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountOnRKColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM aTable";
+String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM 
"+tableName;
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
@@ -101,15 +95,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountWithGroupBy() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM aTable 
group by A_STRING";
+String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM 
"+tableName+" group by A_STRING";
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 

[1/2] phoenix git commit: PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan Wang)

2017-09-15 Thread jamestaylor
Repository: phoenix
Updated Branches:
  refs/heads/master 052490e09 -> 6c3bcb6a9


PHOENIX-4209 Disallow DML operations on connections with CURRENT_SCN set (Ethan 
Wang)


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

Branch: refs/heads/master
Commit: 6c3bcb6a94b48496d02830747ddd6fcb0fa833af
Parents: 26f45f0
Author: James Taylor 
Authored: Fri Sep 15 10:21:42 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:21:55 2017 -0700

--
 .../apache/phoenix/end2end/DistinctCountIT.java | 102 ---
 1 file changed, 40 insertions(+), 62 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/6c3bcb6a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
index a7482cb..34ce4f1 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/DistinctCountIT.java
@@ -45,26 +45,22 @@ import java.sql.ResultSet;
 import java.sql.Types;
 import java.util.Properties;
 
-import org.apache.phoenix.schema.TableAlreadyExistsException;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
 import org.junit.Test;
 
 
-public class DistinctCountIT extends BaseClientManagedTimeIT {
+public class DistinctCountIT extends ParallelStatsDisabledIT {
 
 @Test
 public void testDistinctCountOnColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
-
-String query = "SELECT count(DISTINCT A_STRING) FROM aTable";
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
+String query = "SELECT count(DISTINCT A_STRING) FROM "+tableName;
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
-Connection conn = DriverManager.getConnection(getUrl(), props);
+Connection conn = DriverManager.getConnection(getUrl(),props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
 ResultSet rs = statement.executeQuery();
@@ -78,15 +74,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountOnRKColumn() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM aTable";
+String query = "SELECT count(DISTINCT ORGANIZATION_ID) FROM 
"+tableName;
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-   
  // timestamp 2
 Connection conn = DriverManager.getConnection(getUrl(), props);
 try {
 PreparedStatement statement = conn.prepareStatement(query);
@@ -101,15 +95,13 @@ public class DistinctCountIT extends 
BaseClientManagedTimeIT {
 
 @Test
 public void testDistinctCountWithGroupBy() throws Exception {
-long ts = nextTimestamp();
 String tenantId = getOrganizationId();
-initATableValues(tenantId, null, getDefaultSplits(tenantId), null, ts);
+String tableName = generateUniqueName();
+initATableValues(tenantId, null, getDefaultSplits(tenantId), null, 
tableName);
 
-String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM aTable 
group by A_STRING";
+String query = "SELECT A_STRING, count(DISTINCT B_STRING) FROM 
"+tableName+" group by A_STRING";
 
 Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
-props.setProperty(PhoenixRuntime.CURRENT_SCN_ATTRIB, Long.toString(ts 
+ 2)); // Execute at
-

[2/2] phoenix git commit: PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like other poms

2017-09-15 Thread jamestaylor
PHOENIX-4211 Change tephra dependency in phoenix-kafka to test dependency like 
other poms


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

Branch: refs/heads/master
Commit: 26f45f0fafe7bdefec23a5b1ade7c30722c0b93d
Parents: 052490e
Author: James Taylor 
Authored: Thu Sep 14 09:55:17 2017 -0700
Committer: James Taylor 
Committed: Fri Sep 15 10:21:55 2017 -0700

--
 phoenix-kafka/pom.xml | 26 ++
 1 file changed, 6 insertions(+), 20 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/26f45f0f/phoenix-kafka/pom.xml
--
diff --git a/phoenix-kafka/pom.xml b/phoenix-kafka/pom.xml
index 787afad..0969fb1 100644
--- a/phoenix-kafka/pom.xml
+++ b/phoenix-kafka/pom.xml
@@ -50,26 +50,6 @@

 

-   
-   
-   org.apache.tephra
-   tephra-api
-   
-   
-   org.apache.tephra
-   tephra-core
-   
-   
-   org.apache.tephra
-   tephra-core
-   test-jar
-   test
-   
-   
-   org.apache.tephra
-   tephra-hbase-compat-1.1
-   
-


org.antlr
@@ -338,6 +318,12 @@
org.apache.flume
flume-ng-core

+
+  org.apache.tephra
+  tephra-core
+  test-jar
+  test
+

 




Build failed in Jenkins: Phoenix Compile Compatibility with HBase #406

2017-09-15 Thread Apache Jenkins Server
See 


--
Started by timer
[EnvInject] - Loading node environment variables.
Building remotely on H25 (couchdbtest ubuntu xenial) in workspace 

[Phoenix_Compile_Compat_wHBase] $ /bin/bash /tmp/jenkins1403775459218725969.sh
core file size  (blocks, -c) 0
data seg size   (kbytes, -d) unlimited
scheduling priority (-e) 0
file size   (blocks, -f) unlimited
pending signals (-i) 386417
max locked memory   (kbytes, -l) 64
max memory size (kbytes, -m) unlimited
open files  (-n) 6
pipe size(512 bytes, -p) 8
POSIX message queues (bytes, -q) 819200
real-time priority  (-r) 0
stack size  (kbytes, -s) 8192
cpu time   (seconds, -t) unlimited
max user processes  (-u) 10240
virtual memory  (kbytes, -v) unlimited
file locks  (-x) unlimited
core id : 0
core id : 1
core id : 2
core id : 3
core id : 4
core id : 5
physical id : 0
physical id : 1
MemTotal:   98958120 kB
MemFree:15736852 kB
Filesystem  Size  Used Avail Use% Mounted on
udev 48G 0   48G   0% /dev
tmpfs   9.5G 1010M  8.5G  11% /run
/dev/sda1   364G  193G  153G  56% /
tmpfs48G  516K   48G   1% /dev/shm
tmpfs   5.0M 0  5.0M   0% /run/lock
tmpfs48G 0   48G   0% /sys/fs/cgroup
tmpfs   9.5G 0  9.5G   0% /run/user/10025
apache-maven-2.2.1
apache-maven-3.0.4
apache-maven-3.0.5
apache-maven-3.2.1
apache-maven-3.2.5
apache-maven-3.3.3
apache-maven-3.3.9
apache-maven-3.5.0
latest
latest2
latest3


===
Verifying compile level compatibility with HBase 0.98 with Phoenix 
4.x-HBase-0.98
===

Cloning into 'hbase'...
Switched to a new branch '0.98'
Branch 0.98 set up to track remote branch 0.98 from origin.

main:
 [exec] 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/hbase/hbase-common 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/hbase/hbase-common
 [exec] 
~/jenkins-slave/workspace/Phoenix_Compile_Compat_wHBase/hbase/hbase-common

main:
[mkdir] Created dir: 

 [exec] tar: hadoop-snappy-nativelibs.tar: Cannot open: No such file or 
directory
 [exec] tar: Error is not recoverable: exiting now
 [exec] Result: 2

main:
[mkdir] Created dir: 

 [copy] Copying 20 files to 

[mkdir] Created dir: 

[mkdir] Created dir: 


main:
[mkdir] Created dir: 

 [copy] Copying 17 files to 

[mkdir] Created dir: 


main:
[mkdir] Created dir: 

 [copy] Copying 1 file to 

[mkdir] Created dir: 


HBase pom.xml:

Got HBase version as 0.98.25-SNAPSHOT
Cloning into 'phoenix'...
Switched to a new branch '4.x-HBase-0.98'
Branch 4.x-HBase-0.98 set up to track remote branch 4.x-HBase-0.98 from origin.
ANTLR Parser Generator  Version 3.5.2
Output file 

 does not exist: must build 

PhoenixSQL.g


===
Verifying compile level compatibility with HBase branch-1.3 with Phoenix master