svn commit: r1829397 - in /phoenix/site: publish/language/ publish/phoenixcon-2018/ source/src/site/resources/phoenixcon-2018/

2018-04-17 Thread elserj 
Author: elserj
Date: Tue Apr 17 20:35:08 2018
New Revision: 1829397

URL: http://svn.apache.org/viewvc?rev=1829397=rev
Log:
Extend cfp 

Modified:
phoenix/site/publish/language/datatypes.html
phoenix/site/publish/language/functions.html
phoenix/site/publish/language/index.html
phoenix/site/publish/phoenixcon-2018/feed.xml
phoenix/site/publish/phoenixcon-2018/index.html
phoenix/site/source/src/site/resources/phoenixcon-2018/feed.xml
phoenix/site/source/src/site/resources/phoenixcon-2018/index.html

Modified: phoenix/site/publish/language/datatypes.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/language/datatypes.html?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/publish/language/datatypes.html (original)
+++ phoenix/site/publish/language/datatypes.html Tue Apr 17 20:35:08 2018
@@ -1,7 +1,7 @@
 
 
 
 

Modified: phoenix/site/publish/language/functions.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/language/functions.html?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/publish/language/functions.html (original)
+++ phoenix/site/publish/language/functions.html Tue Apr 17 20:35:08 2018
@@ -1,7 +1,7 @@
 
 
 
 

Modified: phoenix/site/publish/language/index.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/language/index.html?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/publish/language/index.html (original)
+++ phoenix/site/publish/language/index.html Tue Apr 17 20:35:08 2018
@@ -1,7 +1,7 @@
 
 
 
 

Modified: phoenix/site/publish/phoenixcon-2018/feed.xml
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/phoenixcon-2018/feed.xml?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/publish/phoenixcon-2018/feed.xml (original)
+++ phoenix/site/publish/phoenixcon-2018/feed.xml Tue Apr 17 20:35:08 2018
@@ -4,7 +4,7 @@
   https://jekyllrb.com/; version="3.7.3">Jekyll
   https://phoenix.apache.org/phoenixcon-2018//phoenixcon-2018/feed.xml; 
rel="self" type="application/atom+xml" />
   https://phoenix.apache.org/phoenixcon-2018//phoenixcon-2018/; 
rel="alternate" type="text/html" />
-  2018-04-12T13:04:32-04:00
+  2018-04-17T16:30:47-04:00
   https://phoenix.apache.org/phoenixcon-2018//phoenixcon-2018/
 
   

Modified: phoenix/site/publish/phoenixcon-2018/index.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/phoenixcon-2018/index.html?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/publish/phoenixcon-2018/index.html (original)
+++ phoenix/site/publish/phoenixcon-2018/index.html Tue Apr 17 20:35:08 2018
@@ -135,7 +135,7 @@


  The event's call for proposals is available on https://easychair.org/conferences/?conf=pc18;>EasyChair.
- The CFP will be open until 2018/04/16. Please submit your talks 
as soon as possible!
+ The CFP will be open until 2018/04/20. Please submit your talks 
as soon as possible!
  All submissions will be reviewed by a group of individuals 
from the Apache Phoenix PMC.



Modified: phoenix/site/source/src/site/resources/phoenixcon-2018/feed.xml
URL: 
http://svn.apache.org/viewvc/phoenix/site/source/src/site/resources/phoenixcon-2018/feed.xml?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/source/src/site/resources/phoenixcon-2018/feed.xml (original)
+++ phoenix/site/source/src/site/resources/phoenixcon-2018/feed.xml Tue Apr 17 
20:35:08 2018
@@ -4,7 +4,7 @@
   https://jekyllrb.com/; version="3.7.3">Jekyll
   https://phoenix.apache.org/phoenixcon-2018//phoenixcon-2018/feed.xml; 
rel="self" type="application/atom+xml" />
   https://phoenix.apache.org/phoenixcon-2018//phoenixcon-2018/; 
rel="alternate" type="text/html" />
-  2018-04-12T13:04:32-04:00
+  2018-04-17T16:30:47-04:00
   https://phoenix.apache.org/phoenixcon-2018//phoenixcon-2018/
 
   

Modified: phoenix/site/source/src/site/resources/phoenixcon-2018/index.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/source/src/site/resources/phoenixcon-2018/index.html?rev=1829397=1829396=1829397=diff
==
--- phoenix/site/source/src/site/resources/phoenixcon-2018/index.html (original)
+++ phoenix/site/source/src/site/resources/phoenixcon-2018/index.html Tue Apr 
17 20:35:08 2018
@@ -135,7 +135,7 @@


  The event's call for proposals is available on https://easychair.org/conferences/?conf=pc18;>EasyChair.
- The CFP will be open until 2018/04/16. Please submit your talks 
as soon as

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

2018-04-17 Thread Apache Jenkins Server 
See 


Changes:

[ankitsinghal59] Keep Ring buffer size small by default and avoid starting 
disruptor for

--
[...truncated 106.71 KB...]
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.101 s 
- in org.apache.phoenix.end2end.join.HashJoinCacheIT
[INFO] Running org.apache.phoenix.end2end.join.HashJoinNoIndexIT
[INFO] Running org.apache.phoenix.end2end.join.HashJoinGlobalIndexIT
[INFO] Running org.apache.phoenix.end2end.join.HashJoinLocalIndexIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 146.509 
s - in org.apache.phoenix.end2end.index.txn.RollbackIT
[INFO] Running org.apache.phoenix.end2end.join.SortMergeJoinGlobalIndexIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 200.536 
s - in org.apache.phoenix.end2end.join.HashJoinMoreIT
[INFO] Running org.apache.phoenix.end2end.join.SortMergeJoinLocalIndexIT
[INFO] Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 463.078 
s - in org.apache.phoenix.end2end.join.HashJoinNoIndexIT
[INFO] Running org.apache.phoenix.end2end.join.SortMergeJoinNoIndexIT
[INFO] Tests run: 80, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 
1,165.739 s - in org.apache.phoenix.end2end.index.MutableIndexIT
[INFO] Running org.apache.phoenix.end2end.join.SubqueryIT
[INFO] Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 704.669 
s - in org.apache.phoenix.end2end.join.HashJoinGlobalIndexIT
[INFO] Running org.apache.phoenix.end2end.join.SubqueryUsingSortMergeJoinIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 677.959 
s - in org.apache.phoenix.end2end.join.SortMergeJoinGlobalIndexIT
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 26.517 s 
- in org.apache.phoenix.end2end.salted.SaltedTableIT
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 364.357 
s - in org.apache.phoenix.end2end.join.SortMergeJoinNoIndexIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 873.641 
s - in org.apache.phoenix.end2end.join.HashJoinLocalIndexIT
[INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 53.797 s 
- in org.apache.phoenix.end2end.salted.SaltedTableUpsertSelectIT
[INFO] Running org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.337 s 
- in org.apache.phoenix.end2end.salted.SaltedTableVarLengthRowKeyIT
[INFO] Running org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.22 s - 
in org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Running org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Running org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.967 s 
- in org.apache.phoenix.iterate.PhoenixQueryTimeoutIT
[INFO] Running org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 42.855 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: 14.468 s 
- in org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Running org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 73.942 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 17.324 s 
- in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 823.421 
s - in org.apache.phoenix.end2end.join.SortMergeJoinLocalIndexIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 271.686 
s - in org.apache.phoenix.end2end.join.SubqueryUsingSortMergeJoinIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 105.641 
s - in org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 95.891 s 
- in org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 395.09 
s - in org.apache.phoenix.end2end.join.SubqueryIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 33.214 s 
- in

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

2018-04-17 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
[ankitsinghal59] Keep Ring buffer size small by default and avoid starting disruptor for



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

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

2018-04-17 Thread Apache Jenkins Server 
4.x-HBase-1.3 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.3

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

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

Changes
[ankitsinghal59] Keep Ring buffer size small by default and avoid starting disruptor for



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

Build failed in Jenkins: Phoenix | Master #1997

2018-04-17 Thread Apache Jenkins Server 
See 


Changes:

[ankitsinghal59] Keep Ring buffer size small by default and avoid starting 
disruptor for

--
[...truncated 112.46 KB...]
[INFO] Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 46.619 s 
- in org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 18.714 s 
- in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 94.233 s 
- in org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 76.164 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 29.41 s 
- in org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 653.45 
s - in org.apache.phoenix.end2end.join.SortMergeJoinGlobalIndexIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 96.766 s 
- in org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 824.165 
s - in org.apache.phoenix.end2end.join.HashJoinLocalIndexIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 819.718 
s - in org.apache.phoenix.end2end.join.SortMergeJoinLocalIndexIT
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 532.049 
s - in org.apache.phoenix.end2end.join.SubqueryUsingSortMergeJoinIT
[WARNING] Tests run: 52, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
362.934 s - in org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 431.095 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] 
[INFO] Results:
[INFO] 
[ERROR] Failures: 
[ERROR]   ConcurrentMutationsIT.testConcurrentDeletesAndUpsertValues:214 
Expected to find PK in data table: (0,0)
[ERROR] Errors: 
[ERROR]   
OrderByIT.testOrderByReverseOptimizationWithNUllsLastBug3491:969->doTestOrderByReverseOptimizationWithNUllsLastBug3491:1017->assertResultSet:1185
 ยป SQLTimeout
[INFO] 
[ERROR] Tests run: 3420, Failures: 1, Errors: 1, Skipped: 7
[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.ChangePermissionsIT
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 42.971 s 
- in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running 
org.apache.phoenix.end2end.ColumnEncodedImmutableNonTxStatsCollectorIT
[INFO] Running 
org.apache.phoenix.end2end.ColumnEncodedMutableNonTxStatsCollectorIT
[INFO] Running 
org.apache.phoenix.end2end.ColumnEncodedImmutableTxStatsCollectorIT
[INFO] Running org.apache.phoenix.end2end.ColumnEncodedMutableTxStatsCollectorIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 13.69 s 
- in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 42.282 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.733 s 
- in org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Running org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.083 s 
- in org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.CostBasedDecisionIT
[INFO] Running org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Running org.apache.phoenix.end2end.DropSchemaIT
[WARNING] Tests run: 26, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
178.52 s - in 
org.apache.phoenix.end2end.ColumnEncodedImmutableNonTxStatsCollectorIT

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

2018-04-17 Thread Apache Jenkins Server 
See 


Changes:

[ankitsinghal59] Keep Ring buffer size small by default and avoid starting 
disruptor for

--
[...truncated 416.38 KB...]
[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
[ERROR] Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 24.838 
s <<< FAILURE! - in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[ERROR] 
testReplayEditsWrittenViaHRegion(org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT)
  Time elapsed: 24.837 s  <<< FAILURE!
java.lang.AssertionError: Index wasn't propertly updated from WAL replay! 
expected:<1> but was:<0>
at 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT.testReplayEditsWrittenViaHRegion(WALReplayWithIndexWritesAndCompressedWALIT.java:228)

[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.685 s 
- in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running 
org.apache.phoenix.end2end.ColumnEncodedImmutableTxStatsCollectorIT
[INFO] Running 
org.apache.phoenix.end2end.ColumnEncodedImmutableNonTxStatsCollectorIT
[INFO] Running 
org.apache.phoenix.end2end.ColumnEncodedMutableNonTxStatsCollectorIT
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running org.apache.phoenix.end2end.ColumnEncodedMutableTxStatsCollectorIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.475 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.844 s 
- in org.apache.phoenix.end2end.ContextClassloaderIT
[WARNING] Tests run: 26, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
86.965 s - in 
org.apache.phoenix.end2end.ColumnEncodedImmutableNonTxStatsCollectorIT
[WARNING] Tests run: 26, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
87.748 s - in 
org.apache.phoenix.end2end.ColumnEncodedImmutableTxStatsCollectorIT
[WARNING] Tests run: 26, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
90.025 s - in 
org.apache.phoenix.end2end.ColumnEncodedMutableNonTxStatsCollectorIT
[WARNING] Tests run: 26, Failures: 0, Errors: 0, Skipped: 4, Time elapsed: 
88.945 s - in org.apache.phoenix.end2end.ColumnEncodedMutableTxStatsCollectorIT
[INFO] Running org.apache.phoenix.end2end.CostBasedDecisionIT
[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: 2.856 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: 7.233 s 
- in org.apache.phoenix.end2end.DropSchemaIT
[INFO] Running org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running org.apache.phoenix.end2end.IndexExtendedIT
[INFO] Running org.apache.phoenix.end2end.IndexScrutinyToolIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 78.188 
s - in org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Running org.apache.phoenix.end2end.IndexToolForPartialBuildIT
[INFO] Tests run: 32, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 85.918 
s - in org.apache.phoenix.end2end.IndexExtendedIT
[INFO] Tests run: 12, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 117.551 
s - in org.apache.phoenix.end2end.FlappingLocalIndexIT
[INFO] Running 
org.apache.phoenix.end2end.IndexToolForPartialBuildWithNamespaceEnabledIT
[INFO] Running org.apache.phoenix.end2end.IndexToolIT
[INFO] Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 364.35 
s - in org.apache.phoenix.end2end.CostBasedDecisionIT
[INFO] Tests run: 33, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 324.616 
s - in org.apache.phoenix.end2end.IndexScrutinyToolIT
[INFO] Running org.apache.phoenix.end2end.MigrateSystemTablesToSystemNamespaceIT
[INFO] Running org.apache.phoenix.end2end.LocalIndexSplitMergeIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 76.511 s 
- in org.apache.phoenix.end2end.LocalIndexSplitMergeIT
[INFO] Running

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

2018-04-17 Thread Apache Jenkins Server 
See 


--
[...truncated 37.15 KB...]
  symbol:   class HBaseRpcController
  location: class 
org.apache.hadoop.hbase.ipc.controller.ClientRpcControllerFactory
[ERROR] 
:[52,9]
 cannot find symbol
  symbol:   class HBaseRpcController
  location: class 
org.apache.hadoop.hbase.ipc.controller.ClientRpcControllerFactory
[ERROR] 
:[180,14]
 cannot find symbol
  symbol: class MetricRegistry
[ERROR] 
:[179,7]
 method does not override or implement a method from a supertype
[ERROR] 
:[454,78]
 cannot find symbol
  symbol: class HBaseRpcController
[ERROR] 
:[432,17]
 cannot find symbol
  symbol: class HBaseRpcController
[ERROR] Failed to execute goal 
org.apache.maven.plugins:maven-compiler-plugin:3.0:compile (default-compile) on 
project phoenix-core: Compilation failure: Compilation failure: 
[ERROR] 
:[34,39]
 cannot find symbol
[ERROR]   symbol:   class MetricRegistry
[ERROR]   location: package org.apache.hadoop.hbase.metrics
[ERROR] 
:[144,16]
 cannot find symbol
[ERROR]   symbol:   class MetricRegistry
[ERROR]   location: class 
org.apache.phoenix.coprocessor.PhoenixMetaDataCoprocessorHost.PhoenixMetaDataControllerEnvironment
[ERROR] 
:[24,35]
 cannot find symbol
[ERROR]   symbol:   class DelegatingHBaseRpcController
[ERROR]   location: package org.apache.hadoop.hbase.ipc
[ERROR] 
:[25,35]
 cannot find symbol
[ERROR]   symbol:   class HBaseRpcController
[ERROR]   location: package org.apache.hadoop.hbase.ipc
[ERROR] 
:[37,37]
 cannot find symbol
[ERROR]   symbol: class DelegatingHBaseRpcController
[ERROR] 
:[56,38]
 cannot find symbol
[ERROR]   symbol:   class HBaseRpcController
[ERROR]   location: class 
org.apache.hadoop.hbase.ipc.controller.MetadataRpcController
[ERROR] 
:[26,35]
 cannot find symbol
[ERROR]   symbol:   class HBaseRpcController
[ERROR]   location: package org.apache.hadoop.hbase.ipc
[ERROR] 
:[40,12]
 cannot find symbol
[ERROR]   symbol:   class HBaseRpcController
[ERROR]   location: class 
org.apache.hadoop.hbase.ipc.controller.InterRegionServerMetadataRpcControllerFactory
[ERROR] 
:[46,12]
 cannot find symbol
[ERROR]   symbol:   class HBaseRpcController
[ERROR]   location: class 
org.apache.hadoop.hbase.ipc.controller.InterRegionServerMetadataRpcControllerFactory
[ERROR]

phoenix git commit: Keep Ring buffer size small by default and avoid starting disruptor for server connection

2018-04-17 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 ea709974d -> e723be24e


Keep Ring buffer size small by default and avoid starting disruptor for server 
connection


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

Branch: refs/heads/4.x-HBase-1.1
Commit: e723be24e6e62ab6c9ba9116aaa76607d0ad4a64
Parents: ea70997
Author: Ankit Singhal 
Authored: Tue Apr 17 15:22:35 2018 +0530
Committer: Ankit Singhal 
Committed: Tue Apr 17 15:22:35 2018 +0530

--
 .../org/apache/phoenix/log/QueryLoggerDisruptor.java |  2 +-
 .../phoenix/query/ConnectionQueryServicesImpl.java   | 15 +--
 .../main/java/org/apache/phoenix/util/QueryUtil.java | 14 --
 3 files changed, 22 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/e723be24/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
index b548d6c..1f2240e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
@@ -43,7 +43,7 @@ public class QueryLoggerDisruptor implements Closeable{
 private volatile Disruptor disruptor;
 private boolean isClosed = false;
 //number of elements to create within the ring buffer.
-private static final int RING_BUFFER_SIZE = 256 * 1024;
+private static final int RING_BUFFER_SIZE = 8 * 1024;
 private static final Log LOG = 
LogFactory.getLog(QueryLoggerDisruptor.class);
 private static final String DEFAULT_WAIT_STRATEGY = 
BlockingWaitStrategy.class.getName();
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/e723be24/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index b61d8ce..5e43b1d 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -194,7 +194,6 @@ import 
org.apache.phoenix.schema.ColumnFamilyNotFoundException;
 import org.apache.phoenix.schema.EmptySequenceCacheException;
 import org.apache.phoenix.schema.FunctionNotFoundException;
 import org.apache.phoenix.schema.MetaDataClient;
-import org.apache.phoenix.schema.MetaDataSplitPolicy;
 import org.apache.phoenix.schema.NewerSchemaAlreadyExistsException;
 import org.apache.phoenix.schema.NewerTableAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
@@ -242,6 +241,7 @@ import org.apache.phoenix.util.PhoenixContextExecutor;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PhoenixStopWatch;
 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.ServerUtil;
@@ -405,11 +405,14 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
 this.maxConnectionsAllowed = 
config.getInt(QueryServices.CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS,
 
QueryServicesOptions.DEFAULT_CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS);
 this.shouldThrottleNumConnections = (maxConnectionsAllowed > 0);
-try {
-this.queryDisruptor = new QueryLoggerDisruptor(this.config);
-} catch (SQLException e) {
-logger.warn("Unable to initiate qeuery logging service !!");
-e.printStackTrace();
+if (!QueryUtil.isServerConnection(props)) {
+//Start queryDistruptor everytime as log level can be change at 
connection level as well, but we can avoid starting for server connections.
+try {
+this.queryDisruptor = new QueryLoggerDisruptor(this.config);
+} catch (SQLException e) {
+logger.warn("Unable to initiate qeuery logging service !!");
+e.printStackTrace();
+}
 }
 
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/e723be24/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java

phoenix git commit: Keep Ring buffer size small by default and avoid starting disruptor for server connection

2018-04-17 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 07125f25e -> eda63737e


Keep Ring buffer size small by default and avoid starting disruptor for server 
connection


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

Branch: refs/heads/4.x-HBase-0.98
Commit: eda63737ebb1754c205580c45d3169303dd1143c
Parents: 07125f2
Author: Ankit Singhal 
Authored: Tue Apr 17 15:18:22 2018 +0530
Committer: Ankit Singhal 
Committed: Tue Apr 17 15:18:22 2018 +0530

--
 .../apache/phoenix/log/QueryLoggerDisruptor.java|  2 +-
 .../phoenix/query/ConnectionQueryServicesImpl.java  | 16 ++--
 .../java/org/apache/phoenix/util/QueryUtil.java | 14 --
 3 files changed, 23 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/eda63737/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
index b548d6c..1f2240e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
@@ -43,7 +43,7 @@ public class QueryLoggerDisruptor implements Closeable{
 private volatile Disruptor disruptor;
 private boolean isClosed = false;
 //number of elements to create within the ring buffer.
-private static final int RING_BUFFER_SIZE = 256 * 1024;
+private static final int RING_BUFFER_SIZE = 8 * 1024;
 private static final Log LOG = 
LogFactory.getLog(QueryLoggerDisruptor.class);
 private static final String DEFAULT_WAIT_STRATEGY = 
BlockingWaitStrategy.class.getName();
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/eda63737/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index 7a5b8d7..3d22f5b 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -242,6 +242,7 @@ import org.apache.phoenix.util.PhoenixContextExecutor;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PhoenixStopWatch;
 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.ServerUtil;
@@ -405,12 +406,15 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
 this.maxConnectionsAllowed = 
config.getInt(QueryServices.CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS,
 
QueryServicesOptions.DEFAULT_CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS);
 this.shouldThrottleNumConnections = (maxConnectionsAllowed > 0);
-try {
-this.queryDisruptor = new QueryLoggerDisruptor(this.config);
-} catch (SQLException e) {
-logger.warn("Unable to initiate qeuery logging service !!");
-e.printStackTrace();
-}
+if (!QueryUtil.isServerConnection(props)) {
+ //Start queryDistruptor everytime as log level can be change at 
connection level as well, but we can avoid starting for server connections.
+ try {
+ this.queryDisruptor = new QueryLoggerDisruptor(this.config);
+ } catch (SQLException e) {
+ logger.warn("Unable to initiate qeuery logging service !!");
+ e.printStackTrace();
+ }
+  }
 
 }
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/eda63737/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java
--
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java
index 24760b2..f5f04a6 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java
@@ -82,6 +82,7 @@ public final class QueryUtil {
  */
 public static final int

phoenix git commit: Keep Ring buffer size small by default and avoid starting disruptor for server connection

2018-04-17 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.2 bc14ad5dc -> cafb150e7


Keep Ring buffer size small by default and avoid starting disruptor for server 
connection


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

Branch: refs/heads/4.x-HBase-1.2
Commit: cafb150e73bee53c86d444a7262295693cefc011
Parents: bc14ad5
Author: Ankit Singhal 
Authored: Tue Apr 17 15:09:29 2018 +0530
Committer: Ankit Singhal 
Committed: Tue Apr 17 15:09:29 2018 +0530

--
 .../org/apache/phoenix/log/QueryLoggerDisruptor.java |  2 +-
 .../phoenix/query/ConnectionQueryServicesImpl.java   | 15 +--
 .../main/java/org/apache/phoenix/util/QueryUtil.java | 14 --
 3 files changed, 22 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/cafb150e/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
index b548d6c..1f2240e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
@@ -43,7 +43,7 @@ public class QueryLoggerDisruptor implements Closeable{
 private volatile Disruptor disruptor;
 private boolean isClosed = false;
 //number of elements to create within the ring buffer.
-private static final int RING_BUFFER_SIZE = 256 * 1024;
+private static final int RING_BUFFER_SIZE = 8 * 1024;
 private static final Log LOG = 
LogFactory.getLog(QueryLoggerDisruptor.class);
 private static final String DEFAULT_WAIT_STRATEGY = 
BlockingWaitStrategy.class.getName();
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/cafb150e/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index 5985705..f5e83f2 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -195,7 +195,6 @@ import 
org.apache.phoenix.schema.ColumnFamilyNotFoundException;
 import org.apache.phoenix.schema.EmptySequenceCacheException;
 import org.apache.phoenix.schema.FunctionNotFoundException;
 import org.apache.phoenix.schema.MetaDataClient;
-import org.apache.phoenix.schema.MetaDataSplitPolicy;
 import org.apache.phoenix.schema.NewerSchemaAlreadyExistsException;
 import org.apache.phoenix.schema.NewerTableAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
@@ -243,6 +242,7 @@ import org.apache.phoenix.util.PhoenixContextExecutor;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PhoenixStopWatch;
 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.ServerUtil;
@@ -406,11 +406,14 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
 this.maxConnectionsAllowed = 
config.getInt(QueryServices.CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS,
 
QueryServicesOptions.DEFAULT_CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS);
 this.shouldThrottleNumConnections = (maxConnectionsAllowed > 0);
-try {
-this.queryDisruptor = new QueryLoggerDisruptor(this.config);
-} catch (SQLException e) {
-logger.warn("Unable to initiate qeuery logging service !!");
-e.printStackTrace();
+if (!QueryUtil.isServerConnection(props)) {
+//Start queryDistruptor everytime as log level can be change at 
connection level as well, but we can avoid starting for server connections.
+try {
+this.queryDisruptor = new QueryLoggerDisruptor(this.config);
+} catch (SQLException e) {
+logger.warn("Unable to initiate qeuery logging service !!");
+e.printStackTrace();
+}
 }
 
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/cafb150e/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java

phoenix git commit: Keep Ring buffer size small by default and avoid starting disruptor for server connection

2018-04-17 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.3 d525ba6a0 -> 3c18a2913


Keep Ring buffer size small by default and avoid starting disruptor for server 
connection


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

Branch: refs/heads/4.x-HBase-1.3
Commit: 3c18a29137a51ae23bf98c612453db2700110e4f
Parents: d525ba6
Author: Ankit Singhal 
Authored: Tue Apr 17 15:09:05 2018 +0530
Committer: Ankit Singhal 
Committed: Tue Apr 17 15:09:05 2018 +0530

--
 .../org/apache/phoenix/log/QueryLoggerDisruptor.java |  2 +-
 .../phoenix/query/ConnectionQueryServicesImpl.java   | 15 +--
 .../main/java/org/apache/phoenix/util/QueryUtil.java | 14 --
 3 files changed, 22 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c18a291/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
index b548d6c..1f2240e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
@@ -43,7 +43,7 @@ public class QueryLoggerDisruptor implements Closeable{
 private volatile Disruptor disruptor;
 private boolean isClosed = false;
 //number of elements to create within the ring buffer.
-private static final int RING_BUFFER_SIZE = 256 * 1024;
+private static final int RING_BUFFER_SIZE = 8 * 1024;
 private static final Log LOG = 
LogFactory.getLog(QueryLoggerDisruptor.class);
 private static final String DEFAULT_WAIT_STRATEGY = 
BlockingWaitStrategy.class.getName();
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c18a291/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index 5985705..f5e83f2 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -195,7 +195,6 @@ import 
org.apache.phoenix.schema.ColumnFamilyNotFoundException;
 import org.apache.phoenix.schema.EmptySequenceCacheException;
 import org.apache.phoenix.schema.FunctionNotFoundException;
 import org.apache.phoenix.schema.MetaDataClient;
-import org.apache.phoenix.schema.MetaDataSplitPolicy;
 import org.apache.phoenix.schema.NewerSchemaAlreadyExistsException;
 import org.apache.phoenix.schema.NewerTableAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
@@ -243,6 +242,7 @@ import org.apache.phoenix.util.PhoenixContextExecutor;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PhoenixStopWatch;
 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.ServerUtil;
@@ -406,11 +406,14 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
 this.maxConnectionsAllowed = 
config.getInt(QueryServices.CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS,
 
QueryServicesOptions.DEFAULT_CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS);
 this.shouldThrottleNumConnections = (maxConnectionsAllowed > 0);
-try {
-this.queryDisruptor = new QueryLoggerDisruptor(this.config);
-} catch (SQLException e) {
-logger.warn("Unable to initiate qeuery logging service !!");
-e.printStackTrace();
+if (!QueryUtil.isServerConnection(props)) {
+//Start queryDistruptor everytime as log level can be change at 
connection level as well, but we can avoid starting for server connections.
+try {
+this.queryDisruptor = new QueryLoggerDisruptor(this.config);
+} catch (SQLException e) {
+logger.warn("Unable to initiate qeuery logging service !!");
+e.printStackTrace();
+}
 }
 
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c18a291/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java

phoenix git commit: Keep Ring buffer size small by default and avoid starting disruptor for server connection

2018-04-17 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/master db0e1eda6 -> 34f93d77a


Keep Ring buffer size small by default and avoid starting disruptor for server 
connection


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

Branch: refs/heads/master
Commit: 34f93d77a37ca7c1e6ac96c2dc7970aafe08b960
Parents: db0e1ed
Author: Ankit Singhal 
Authored: Tue Apr 17 15:08:20 2018 +0530
Committer: Ankit Singhal 
Committed: Tue Apr 17 15:08:20 2018 +0530

--
 .../org/apache/phoenix/log/QueryLoggerDisruptor.java |  2 +-
 .../phoenix/query/ConnectionQueryServicesImpl.java   | 15 +--
 .../main/java/org/apache/phoenix/util/QueryUtil.java | 14 --
 3 files changed, 22 insertions(+), 9 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/34f93d77/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
index b548d6c..1f2240e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
@@ -43,7 +43,7 @@ public class QueryLoggerDisruptor implements Closeable{
 private volatile Disruptor disruptor;
 private boolean isClosed = false;
 //number of elements to create within the ring buffer.
-private static final int RING_BUFFER_SIZE = 256 * 1024;
+private static final int RING_BUFFER_SIZE = 8 * 1024;
 private static final Log LOG = 
LogFactory.getLog(QueryLoggerDisruptor.class);
 private static final String DEFAULT_WAIT_STRATEGY = 
BlockingWaitStrategy.class.getName();
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/34f93d77/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index 5985705..f5e83f2 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -195,7 +195,6 @@ import 
org.apache.phoenix.schema.ColumnFamilyNotFoundException;
 import org.apache.phoenix.schema.EmptySequenceCacheException;
 import org.apache.phoenix.schema.FunctionNotFoundException;
 import org.apache.phoenix.schema.MetaDataClient;
-import org.apache.phoenix.schema.MetaDataSplitPolicy;
 import org.apache.phoenix.schema.NewerSchemaAlreadyExistsException;
 import org.apache.phoenix.schema.NewerTableAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
@@ -243,6 +242,7 @@ import org.apache.phoenix.util.PhoenixContextExecutor;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PhoenixStopWatch;
 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.ServerUtil;
@@ -406,11 +406,14 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
 this.maxConnectionsAllowed = 
config.getInt(QueryServices.CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS,
 
QueryServicesOptions.DEFAULT_CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS);
 this.shouldThrottleNumConnections = (maxConnectionsAllowed > 0);
-try {
-this.queryDisruptor = new QueryLoggerDisruptor(this.config);
-} catch (SQLException e) {
-logger.warn("Unable to initiate qeuery logging service !!");
-e.printStackTrace();
+if (!QueryUtil.isServerConnection(props)) {
+//Start queryDistruptor everytime as log level can be change at 
connection level as well, but we can avoid starting for server connections.
+try {
+this.queryDisruptor = new QueryLoggerDisruptor(this.config);
+} catch (SQLException e) {
+logger.warn("Unable to initiate qeuery logging service !!");
+e.printStackTrace();
+}
 }
 
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/34f93d77/phoenix-core/src/main/java/org/apache/phoenix/util/QueryUtil.java

phoenix git commit: Keep Ring buffer size small by default and avoid starting disruptor for server connection

2018-04-17 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/5.x-HBase-2.0 2a8f0c0fe -> 0e5c6e524


Keep Ring buffer size small by default and avoid starting disruptor for server 
connection


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

Branch: refs/heads/5.x-HBase-2.0
Commit: 0e5c6e52436360892e22e5a3981c236dfe7d6001
Parents: 2a8f0c0
Author: Ankit Singhal 
Authored: Tue Apr 17 15:05:26 2018 +0530
Committer: Ankit Singhal 
Committed: Tue Apr 17 15:05:26 2018 +0530

--
 .../apache/phoenix/log/QueryLoggerDisruptor.java|  2 +-
 .../phoenix/query/ConnectionQueryServicesImpl.java  | 16 +---
 .../java/org/apache/phoenix/util/QueryUtil.java | 14 --
 3 files changed, 22 insertions(+), 10 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/0e5c6e52/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
index b548d6c..1f2240e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/log/QueryLoggerDisruptor.java
@@ -43,7 +43,7 @@ public class QueryLoggerDisruptor implements Closeable{
 private volatile Disruptor disruptor;
 private boolean isClosed = false;
 //number of elements to create within the ring buffer.
-private static final int RING_BUFFER_SIZE = 256 * 1024;
+private static final int RING_BUFFER_SIZE = 8 * 1024;
 private static final Log LOG = 
LogFactory.getLog(QueryLoggerDisruptor.class);
 private static final String DEFAULT_WAIT_STRATEGY = 
BlockingWaitStrategy.class.getName();
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/0e5c6e52/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index ffce2ea..44dce3f 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -102,7 +102,6 @@ import javax.annotation.concurrent.GuardedBy;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionLocation;
-import org.apache.hadoop.hbase.KeepDeletedCells;
 import org.apache.hadoop.hbase.NamespaceDescriptor;
 import org.apache.hadoop.hbase.NamespaceNotFoundException;
 import org.apache.hadoop.hbase.TableExistsException;
@@ -201,7 +200,6 @@ import 
org.apache.phoenix.schema.ColumnFamilyNotFoundException;
 import org.apache.phoenix.schema.EmptySequenceCacheException;
 import org.apache.phoenix.schema.FunctionNotFoundException;
 import org.apache.phoenix.schema.MetaDataClient;
-import org.apache.phoenix.schema.MetaDataSplitPolicy;
 import org.apache.phoenix.schema.NewerSchemaAlreadyExistsException;
 import org.apache.phoenix.schema.NewerTableAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
@@ -249,6 +247,7 @@ import org.apache.phoenix.util.PhoenixContextExecutor;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PhoenixStopWatch;
 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.ServerUtil;
@@ -412,11 +411,14 @@ public class ConnectionQueryServicesImpl extends 
DelegateQueryServices implement
 this.maxConnectionsAllowed = 
config.getInt(QueryServices.CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS,
 
QueryServicesOptions.DEFAULT_CLIENT_CONNECTION_MAX_ALLOWED_CONNECTIONS);
 this.shouldThrottleNumConnections = (maxConnectionsAllowed > 0);
-try {
-this.queryDisruptor = new QueryLoggerDisruptor(this.config);
-} catch (SQLException e) {
-logger.warn("Unable to initiate qeuery logging service !!");
-e.printStackTrace();
+if (!QueryUtil.isServerConnection(props)) {
+//Start queryDistruptor everytime as log level can be change at 
connection level as well, but we can avoid starting for server connections.
+