date:20160817

svn commit: r1756700 - in /phoenix/site: publish/index.html publish/news.html source/src/site/markdown/index.md source/src/site/markdown/news.md

2016-08-17 Thread jamestaylor

Author: jamestaylor
Date: Thu Aug 18 01:25:47 2016
New Revision: 1756700

URL: http://svn.apache.org/viewvc?rev=1756700=rev
Log:
Announce 4.8 release

Modified:
phoenix/site/publish/index.html
phoenix/site/publish/news.html
phoenix/site/source/src/site/markdown/index.md
phoenix/site/source/src/site/markdown/news.md

Modified: phoenix/site/publish/index.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/index.html?rev=1756700=1756699=1756700=diff
==
--- phoenix/site/publish/index.html (original)
+++ phoenix/site/publish/index.html Thu Aug 18 01:25:47 2016
@@ -1,7 +1,7 @@
 
 
 
 
@@ -181,7 +181,7 @@
   
  
 
-News: Support now available for latest http://docs.aws.amazon.com/ElasticMapReduce/latest/ReleaseGuide/emr-phoenix.html;>Apache
 Phoenix in Amazon EMR
 https://twitter.com/ApachePhoenix;> 
+News: Phoenix 4.8 has been https://blogs.apache.org/phoenix/entry/announcing_phoenix_4_8_released;>released

 https://twitter.com/ApachePhoenix;> 

   
  

Modified: phoenix/site/publish/news.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/news.html?rev=1756700=1756699=1756700=diff
==
--- phoenix/site/publish/news.html (original)
+++ phoenix/site/publish/news.html Thu Aug 18 01:25:47 2016
@@ -1,7 +1,7 @@
 
 
 
 
@@ -155,6 +155,10 @@
  
   

+   https://blogs.apache.org/phoenix/entry/announcing_phoenix_4_8_released;>Announcing
 Phoenix 4.8 released (August 10, 2016) 
+
+   
+   
http://docs.aws.amazon.com/ElasticMapReduce/latest/ReleaseGuide/emr-phoenix.html;>Announcing
 support for latest Phoenix in Amazon EMR (June 2, 2016) 
 


Modified: phoenix/site/source/src/site/markdown/index.md
URL: 
http://svn.apache.org/viewvc/phoenix/site/source/src/site/markdown/index.md?rev=1756700=1756699=1756700=diff
==
--- phoenix/site/source/src/site/markdown/index.md (original)
+++ phoenix/site/source/src/site/markdown/index.md Thu Aug 18 01:25:47 2016
@@ -45,7 +45,7 @@
 
 
 News:
-Support now available for latest [Apache Phoenix in Amazon 
EMR](http://docs.aws.amazon.com/ElasticMapReduce/latest/ReleaseGuide/emr-phoenix.html)
 
+Phoenix 4.8 has been 
[released](https://blogs.apache.org/phoenix/entry/announcing_phoenix_4_8_released)
 

 
 
 ## Overview

Modified: phoenix/site/source/src/site/markdown/news.md
URL: 
http://svn.apache.org/viewvc/phoenix/site/source/src/site/markdown/news.md?rev=1756700=1756699=1756700=diff
==
--- phoenix/site/source/src/site/markdown/news.md (original)
+++ phoenix/site/source/src/site/markdown/news.md Thu Aug 18 01:25:47 2016
@@ -1,6 +1,8 @@
 # Apache Phoenix News
 
 
+ [Announcing Phoenix 4.8 
released](https://blogs.apache.org/phoenix/entry/announcing_phoenix_4_8_released)
 (August 10, 2016)
+
  [Announcing support for latest Phoenix in Amazon 
EMR](http://docs.aws.amazon.com/ElasticMapReduce/latest/ReleaseGuide/emr-phoenix.html)
 (June 2, 2016)
 
  [Announcing first ever Phoenix conference on Wed, May 25th 
9am-1pm](http://www.meetup.com/SF-Bay-Area-Apache-Phoenix-Meetup/events/230545182/)
 (April 21, 2016)

svn commit: r1756695 - in /phoenix: phoenix-docs/src/docsrc/help/ site/publish/ site/publish/language/ site/source/src/site/markdown/

2016-08-17 Thread jamestaylor

Author: jamestaylor
Date: Wed Aug 17 23:48:20 2016
New Revision: 1756695

URL: http://svn.apache.org/viewvc?rev=1756695=rev
Log:
Update docs to reflect 4.8 namespace feature (Ankit Singhal)

Modified:
phoenix/phoenix-docs/src/docsrc/help/phoenix.csv
phoenix/site/publish/faq.html
phoenix/site/publish/language/datatypes.html
phoenix/site/publish/language/functions.html
phoenix/site/publish/language/index.html
phoenix/site/publish/paged.html
phoenix/site/publish/tuning.html
phoenix/site/source/src/site/markdown/faq.md
phoenix/site/source/src/site/markdown/paged.md
phoenix/site/source/src/site/markdown/tuning.md

Modified: phoenix/phoenix-docs/src/docsrc/help/phoenix.csv
URL: 
http://svn.apache.org/viewvc/phoenix/phoenix-docs/src/docsrc/help/phoenix.csv?rev=1756695=1756694=1756695=diff
==
--- phoenix/phoenix-docs/src/docsrc/help/phoenix.csv (original)
+++ phoenix/phoenix-docs/src/docsrc/help/phoenix.csv Wed Aug 17 23:48:20 2016
@@ -15,6 +15,7 @@ An optional hint may be used to override
 
 ","
 SELECT * FROM TEST LIMIT 1000;
+SELECT * FROM TEST LIMIT 1000 OFFSET 100;
 SELECT full_name FROM SALES_PERSON WHERE ranking >= 5.0
 UNION ALL SELECT reviewer_name FROM CUSTOMER_REVIEW WHERE score >= 8.0
 "
@@ -288,6 +289,40 @@ UPDATE STATISTICS my_table COLUMNS
 UPDATE STATISTICS my_table SET phoenix.stats.guidepost.width=5000
 "
 
+"Commands","CREATE SCHEMA","
+CREATE SCHEMA [IF NOT EXISTS] schemaName
+","
+creates a schema and corresponding name-space in hbase. To enable namespace 
mapping, see https://phoenix.apache.org/tuning.html
+
+User that execute this command should have admin permissions to create 
namespace in HBase.
+","
+CREATE SCHEMA IF NOT EXISTS my_schema
+CREATE SCHEMA my_schema
+"
+
+"Commands","USE","
+USE { schemaName | DEFAULT }
+","
+Sets a default schema for the connection and is used as a target schema for 
all statements issued from the connection that do not specify schema name 
explicitly.
+USE DEFAULT unset the schema for the connection so that no schema will be used 
for the statements issued from the connection.
+
+schemaName should already be existed for the USE SCHEMA statement to succeed. 
see CREATE SCHEMA for creating schema.
+","
+USE my_schema
+USE DEFAULT
+"
+
+"Commands","DROP SCHEMA","
+DROP SCHEMA [IF EXISTS] schemaName
+","
+Drops a schema and corresponding name-space from hbase. To enable namespace 
mapping, see https://phoenix.apache.org/tuning.html
+
+This statement succeed only when schema doesn't hold any tables.
+","
+DROP SCHEMA IF EXISTS my_schema
+DROP SCHEMA my_schema
+"
+
 "Other Grammar","Options","
 { [familyName .] name= value } [,...]
 ","

Modified: phoenix/site/publish/faq.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/faq.html?rev=1756695=1756694=1756695=diff
==
--- phoenix/site/publish/faq.html (original)
+++ phoenix/site/publish/faq.html Wed Aug 17 23:48:20 2016
@@ -1,7 +1,7 @@
 
 
 
 
@@ -163,6 +163,7 @@
  Why isnât my query 
doing a RANGE SCAN? 
  Should I pool Phoenix 
JDBC Connections? 
  Why does Phoenix add an empty or dummy 
KeyValue when doing an upsert? 
+ How to move existing table with schema to 
namespace? 
  
  
   
@@ -375,6 +376,18 @@ conn.commit();
   Now consider JDBC row which has an integer primary key, and several 
columns which are all null. In order to be able to store the primary key, a 
KeyValue needs to be stored to show that the row is present at all. This column 
is represented by the empty column that youâve noticed. This allows doing a 
âSELECT * FROM TABLEâ and receiving records for all rows, even those whose 
non-pk columns are null. 
   The same issue comes up even if only one column is null for some (or all) 
records. A scan over Phoenix will include the empty column to ensure that rows 
that only consist of the primary key (and have null for all non-key columns) 
will be included in a scan result. 
   
+  
+  How to move existing table with schema to 
namespace? 
+  Pre-requisite: you need 4.8 or higher version to map table to a 
namespae. To enable namespace mapping in configuration, see tuning.html 
+  For kerberized environment, run with the user who have sufficient 
permissiont(âadminâ) to create a namespace. 
+  Table will be mapped to namespace of name âschema_nameâ only , 
Currently we donât support migrating existing table to different schema or 
namespace. 
+  Usage example: 
+  Move table(âtable_nameâ) to namespace of name âschema_nameâ 
+   
+   $  bin/psql.py zookeeper -m 
schema_name.table_name
+ 
+   
+  
 



Modified: phoenix/site/publish/language/datatypes.html
URL: 
http://svn.apache.org/viewvc/phoenix/site/publish/language/datatypes.html?rev=1756695=1756694=1756695=diff

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

2016-08-17 Thread Apache Jenkins Server

See 

Changes:

[tdsilva] PHOENIX-2995 Write performance severely degrades with large number of

--
[...truncated 2105 lines...]
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.AsyncImmutableIndexIT
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT  Time elapsed: 0.004 sec 
 <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT.doSetup(AsyncImmutableIndexIT.java:52)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT.doSetup(AsyncImmutableIndexIT.java:52)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.AsyncImmutableIndexIT.doSetup(AsyncImmutableIndexIT.java:52)

Running org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.009 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT  Time elapsed: 0.009 
sec  <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT.doSetup(ImmutableIndexWithStatsIT.java:52)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT.doSetup(ImmutableIndexWithStatsIT.java:52)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT.doSetup(ImmutableIndexWithStatsIT.java:52)

Running org.apache.phoenix.end2end.index.MutableIndexFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexFailureIT
org.apache.phoenix.end2end.index.MutableIndexFailureIT  Time elapsed: 0.003 sec 
 <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.MutableIndexFailureIT.doSetup(MutableIndexFailureIT.java:115)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.MutableIndexFailureIT.doSetup(MutableIndexFailureIT.java:115)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.MutableIndexFailureIT.doSetup(MutableIndexFailureIT.java:115)

Running org.apache.phoenix.hbase.index.FailForUnsupportedHBaseVersionsIT
Running org.apache.phoenix.end2end.index.MutableIndexReplicationIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.006 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexReplicationIT
org.apache.phoenix.end2end.index.MutableIndexReplicationIT  Time elapsed: 0.005 
sec  <<< ERROR!
java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setupConfigsAndStartCluster(MutableIndexReplicationIT.java:170)
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setUpBeforeClass(MutableIndexReplicationIT.java:108)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setupConfigsAndStartCluster(MutableIndexReplicationIT.java:170)
at 
org.apache.phoenix.end2end.index.MutableIndexReplicationIT.setUpBeforeClass(MutableIndexReplicationIT.java:108)

Running org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.005 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT  Time elapsed: 0.005 
sec  <<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT.doSetup(ReadOnlyIndexFailureIT.java:119)
Caused by: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT.doSetup(ReadOnlyIndexFailureIT.java:119)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT.doSetup(ReadOnlyIndexFailureIT.java:119)

Running org.apache.phoenix.end2end.index.txn.TxWriteFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.txn.TxWriteFailureIT
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT  Time elapsed: 0.003 sec  
<<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT.doSetup(TxWriteFailureIT.java:86)
Caused by:

Jenkins build is back to normal : Phoenix | Master #1364

2016-08-17 Thread Apache Jenkins Server

See

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

2016-08-17 Thread Apache Jenkins Server

See 

Changes:

[tdsilva]  PHOENIX-2995 Write performance severely degrades with large number of

--
[...truncated 693 lines...]
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.719 sec - in 
org.apache.phoenix.trace.PhoenixTraceReaderIT
Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 66.042 sec - in 
org.apache.phoenix.iterate.RoundRobinResultIteratorIT
Running org.apache.phoenix.tx.TransactionIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 84.722 sec - in 
org.apache.phoenix.trace.PhoenixTracingEndToEndIT
Running org.apache.phoenix.tx.TxCheckpointIT
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 77.682 sec - 
in org.apache.phoenix.tx.TxCheckpointIT
Tests run: 21, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 146.523 sec - 
in org.apache.phoenix.tx.TransactionIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 379.672 sec - 
in org.apache.phoenix.end2end.index.LocalIndexIT
Tests run: 128, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 482.366 sec - 
in org.apache.phoenix.end2end.index.IndexIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 583.449 sec - 
in org.apache.phoenix.end2end.index.MutableIndexIT

Results :

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

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

---
 T E S T S
---
Running org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.72 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.AlterSessionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.085 sec - in 
org.apache.phoenix.end2end.AlterSessionIT
Running org.apache.phoenix.end2end.AutoCommitIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.447 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.985 sec - in 
org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.407 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.862 sec - in 
org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.254 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.15 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.121 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.823 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 19.554 sec - 
in org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.116 sec - in 
org.apache.phoenix.end2end.GetSetByteBitFunctionEnd2EndIT
Running org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.LikeExpressionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.44 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.682 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.407 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 7.303 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.368 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 26,

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

2016-08-17 Thread Apache Jenkins Server

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

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

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

Changes
[tdsilva] PHOENIX-2995 Write performance severely degrades with large number of



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

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 94b71e7de -> c5c213d5d


PHOENIX-2995 Write performance severely degrades with large number of views 
(addendum)


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

Branch: refs/heads/4.x-HBase-1.1
Commit: c5c213d5d573357d15b34535666a8c70fe12124a
Parents: 94b71e7
Author: Thomas D'Silva 
Authored: Wed Aug 17 11:55:12 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:56:11 2016 -0700

--
 .../src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java   | 2 --
 1 file changed, 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c5c213d5/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
index 0ebe67f..7bd4b9a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
@@ -113,8 +113,6 @@ import org.apache.phoenix.util.SQLCloseable;
 import org.apache.phoenix.util.SQLCloseables;
 import org.apache.phoenix.util.SchemaUtil;
 import org.apache.tephra.TransactionContext;
-import org.cloudera.htrace.Sampler;
-import org.cloudera.htrace.TraceScope;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Objects;

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 c22020a47 -> 98e665fff


 PHOENIX-2995 Write performance severely degrades with large number of views 
(addendum)


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

Branch: refs/heads/4.x-HBase-1.0
Commit: 98e665fffae832cb82a475a14efa02ceb228efc3
Parents: c22020a
Author: Thomas D'Silva 
Authored: Wed Aug 17 11:55:12 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:55:12 2016 -0700

--
 .../src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java   | 2 --
 1 file changed, 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/98e665ff/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
index 0d09e75..d488eca 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
@@ -113,8 +113,6 @@ import org.apache.phoenix.util.SQLCloseable;
 import org.apache.phoenix.util.SQLCloseables;
 import org.apache.phoenix.util.SchemaUtil;
 import org.apache.tephra.TransactionContext;
-import org.cloudera.htrace.Sampler;
-import org.cloudera.htrace.TraceScope;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Objects;

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.1 ad66cf931 -> 762d8d3ac


PHOENIX-2995 Write performance severely degrades with large number of views 
(addendum)


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

Branch: refs/heads/4.8-HBase-1.1
Commit: 762d8d3ac1463b9dc62e96a5754b9edbfada0872
Parents: ad66cf9
Author: Thomas D'Silva 
Authored: Wed Aug 17 11:55:12 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:56:58 2016 -0700

--
 .../src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java   | 2 --
 1 file changed, 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/762d8d3a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
index 0ebe67f..7bd4b9a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
@@ -113,8 +113,6 @@ import org.apache.phoenix.util.SQLCloseable;
 import org.apache.phoenix.util.SQLCloseables;
 import org.apache.phoenix.util.SchemaUtil;
 import org.apache.tephra.TransactionContext;
-import org.cloudera.htrace.Sampler;
-import org.cloudera.htrace.TraceScope;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Objects;

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.2 fb21cc5fc -> 940e41ef9


PHOENIX-2995 Write performance severely degrades with large number of views 
(addendum)


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

Branch: refs/heads/4.8-HBase-1.2
Commit: 940e41ef92c9eaa8371f3312baea6bead05d0004
Parents: fb21cc5
Author: Thomas D'Silva 
Authored: Wed Aug 17 11:55:12 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:57:03 2016 -0700

--
 .../src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java   | 2 --
 1 file changed, 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/940e41ef/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
index 0ebe67f..7bd4b9a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
@@ -113,8 +113,6 @@ import org.apache.phoenix.util.SQLCloseable;
 import org.apache.phoenix.util.SQLCloseables;
 import org.apache.phoenix.util.SchemaUtil;
 import org.apache.tephra.TransactionContext;
-import org.cloudera.htrace.Sampler;
-import org.cloudera.htrace.TraceScope;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Objects;

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.0 419ac3f2f -> 841e332d7


PHOENIX-2995 Write performance severely degrades with large number of views 
(addendum)


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

Branch: refs/heads/4.8-HBase-1.0
Commit: 841e332d73ba3f98a7dc7c21753d909a9c28cf52
Parents: 419ac3f
Author: Thomas D'Silva 
Authored: Wed Aug 17 11:55:12 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:56:55 2016 -0700

--
 .../src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java   | 2 --
 1 file changed, 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/841e332d/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
index 0d09e75..d488eca 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixConnection.java
@@ -113,8 +113,6 @@ import org.apache.phoenix.util.SQLCloseable;
 import org.apache.phoenix.util.SQLCloseables;
 import org.apache.phoenix.util.SchemaUtil;
 import org.apache.tephra.TransactionContext;
-import org.cloudera.htrace.Sampler;
-import org.cloudera.htrace.TraceScope;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Objects;

Build failed in Jenkins: Phoenix | Master #1363

2016-08-17 Thread Apache Jenkins Server

See 

Changes:

[tdsilva] PHOENIX-2995 Write performance severely degrades with large number of

--
Started by an SCM change
[EnvInject] - Loading node environment variables.
Building remotely on H10 (Ubuntu yahoo-not-h2 ubuntu docker) in workspace 

 > git rev-parse --is-inside-work-tree # timeout=10
Fetching changes from the remote Git repository
 > git config remote.origin.url 
 > https://git-wip-us.apache.org/repos/asf/phoenix.git # timeout=10
Fetching upstream changes from 
https://git-wip-us.apache.org/repos/asf/phoenix.git
 > git --version # timeout=10
 > git -c core.askpass=true fetch --tags --progress 
 > https://git-wip-us.apache.org/repos/asf/phoenix.git 
 > +refs/heads/*:refs/remotes/origin/*
 > git rev-parse origin/master^{commit} # timeout=10
Checking out Revision 3130fa9919ba937d98853f9be8068a0a8a8a96f5 (origin/master)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f 3130fa9919ba937d98853f9be8068a0a8a8a96f5
 > git rev-list 657917bfb15ecd5bef4616458f2c8cd3ede0cf6b # timeout=10
No emails were triggered.
[EnvInject] - Executing scripts and injecting environment variables after the 
SCM step.
[EnvInject] - Injecting as environment variables the properties content 
MAVEN_OPTS=-Xmx3G

[EnvInject] - Variables injected successfully.
[Phoenix-master] $ /bin/bash -xe /tmp/hudson8873697795271369339.sh
+ ls /home/jenkins/.m2/repository/org/apache/htrace
htrace
htrace-core
+ ls /home/jenkins/.m2/repository/org/apache/hbase
hbase
hbase-annotations
hbase-archetype-builder
hbase-archetypes
hbase-assembly
hbase-checkstyle
hbase-client
hbase-client-project
hbase-client-project-archetype
hbase-common
hbase-examples
hbase-external-blockcache
hbase-hadoop1-compat
hbase-hadoop2-compat
hbase-hadoop-compat
hbase-it
hbase-prefix-tree
hbase-procedure
hbase-protocol
hbase-resource-bundle
hbase-rest
hbase-rsgroup
hbase-server
hbase-shaded
hbase-shaded-client
hbase-shaded-client-project
hbase-shaded-client-project-archetype
hbase-shaded-server
hbase-shell
hbase-spark
hbase-testing-util
hbase-thrift
[Phoenix-master] $ /home/jenkins/tools/maven/latest3/bin/mvn -U clean install 
-Dcheckstyle.skip=true
[INFO] Scanning for projects...
[INFO] 
[INFO] Reactor Build Order:
[INFO] 
[INFO] Apache Phoenix
[INFO] Phoenix Core
[INFO] Phoenix - Flume
[INFO] Phoenix - Pig
[INFO] Phoenix Query Server Client
[INFO] Phoenix Query Server
[INFO] Phoenix - Pherf
[INFO] Phoenix - Spark
[INFO] Phoenix - Hive
[INFO] Phoenix Client
[INFO] Phoenix Server
[INFO] Phoenix Assembly
[INFO] Phoenix - Tracing Web Application
[INFO] 
[INFO] 
[INFO] Building Apache Phoenix 4.9.0-HBase-1.2-SNAPSHOT
[INFO] 
[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix ---
[INFO] Deleting 
[INFO] 
[INFO] --- maven-checkstyle-plugin:2.13:check (validate) @ phoenix ---
[INFO] 
[INFO] --- maven-remote-resources-plugin:1.5:process (default) @ phoenix ---
[INFO] 
[INFO] --- maven-source-plugin:2.2.1:jar-no-fork (attach-sources) @ phoenix ---
[INFO] 
[INFO] --- maven-jar-plugin:2.4:test-jar (default) @ phoenix ---
[WARNING] JAR will be empty - no content was marked for inclusion!
[INFO] Building jar: 

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

 to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix/4.9.0-HBase-1.2-SNAPSHOT/phoenix-4.9.0-HBase-1.2-SNAPSHOT-tests.jar
[INFO] 
[INFO] 
[INFO] Building Phoenix Core 4.9.0-HBase-1.2-SNAPSHOT
[INFO] 
[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix-core ---
[INFO] Deleting 

[INFO] 
[INFO] --- maven-checkstyle-plugin:2.13:check (validate) @ phoenix-core ---
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-source

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

2016-08-17 Thread Apache Jenkins Server

See 

Changes:

[tdsilva] PHOENIX-2995 Write performance severely degrades with large number of

--
[...truncated 7252 lines...]
6512/6912 KB   
6512/6912 KB   
6516/6912 KB   
6520/6912 KB   
6520/6912 KB   
6524/6912 KB   
6528/6912 KB   
6528/6912 KB   
6532/6912 KB   
6536/6912 KB   
6536/6912 KB   
6540/6912 KB   
6543/6912 KB   
6544/6912 KB   
6548/6912 KB   
6551/6912 KB   
6552/6912 KB   
6556/6912 KB   
6559/6912 KB   
6560/6912 KB   
6564/6912 KB   
6567/6912 KB   
6568/6912 KB   
6572/6912 KB   
6575/6912 KB   
6576/6912 KB   
6580/6912 KB   
6583/6912 KB   
6584/6912 KB   
6588/6912 KB   
6590/6912 KB   
6592/6912 KB   
6596/6912 KB   
6598/6912 KB   
6600/6912 KB   
6604/6912 KB   
6606/6912 KB   
6608/6912 KB   
6612/6912 KB   
6614/6912 KB   
6616/6912 KB   
6620/6912 KB   
6622/6912 KB   
6624/6912 KB   
6628/6912 KB   
6629/6912 KB   
6632/6912 KB   
6636/6912 KB   
6637/6912 KB   
6640/6912 KB   
6644/6912 KB   
6645/6912 KB   
6648/6912 KB   
6652/6912 KB   
6653/6912 KB   
6656/6912 KB   
6660/6912 KB   
6661/6912 KB   
6664/6912 KB   
6668/6912 KB   
6672/6912 KB   
6672/6912 KB   
6676/6912 KB   
6680/6912 KB   
6680/6912 KB   
6684/6912 KB   
6688/6912 KB   
6688/6912 KB   
6692/6912 KB   
6696/6912 KB   
6696/6912 KB   
6700/6912 KB   
6704/6912 KB   
6704/6912 KB   
6708/6912 KB   
6712/6912 KB   
6712/6912 KB   
6715/6912 KB   
6719/6912 KB   
6720/6912 KB   
6723/6912 KB   
6727/6912 KB   
6728/6912 KB   
6731/6912 KB   
6735/6912 KB   
6736/6912 KB   
6739/6912 KB   
6743/6912 KB   
6744/6912 KB   
6747/6912 KB   
6751/6912 KB   
6752/6912 KB   
6754/6912 KB   
6758/6912 KB   
6760/6912 KB   
6762/6912 KB   
6766/6912 KB   
6768/6912 KB   
6770/6912 KB   
6774/6912 KB   
6776/6912 KB   
6778/6912 KB   
6782/6912 KB   
6784/6912 KB   
6786/6912 KB   
6790/6912 KB   
6792/6912 KB   
6793/6912 KB   
6797/6912 KB   
6800/6912 KB   
6801/6912 KB   
6805/6912 KB   
6808/6912 KB   
6809/6912 KB   
6813/6912 KB   
6816/6912 KB   
6817/6912 KB   
6821/6912 KB   
6824/6912 KB   
6825/6912 KB   
6829/6912 KB   
6832/6912 KB   
6833/6912 KB   
6837/6912 KB   
6840/6912 KB   
6840/6912 KB   
6844/6912 KB   
6848/6912 KB   
6848/6912 KB   
6852/6912 KB   
6856/6912 KB   
6856/6912 KB   
6860/6912 KB   
6864/6912 KB   
6864/6912 KB   
6868/6912 KB   
6872/6912 KB   
6872/6912 KB   
6876/6912 KB   
6879/6912 KB   
6880/6912 KB   
6884/6912 KB   
6887/6912 KB   
6888/6912 KB   
6892/6912 KB   
6895/6912 KB   
6896/6912 KB   
6900/6912 KB   
6903/6912 KB   
6904/6912 KB   
6908/6912 KB   
6911/6912 KB   
6912/6912 KB   
   
Downloaded: 
https://repository.apache.org/content/repositories/releases/org/apache/hbase/hbase-server/1.0.3/hbase-server-1.0.3-tests.jar
 (6912 KB at 160.9 KB/sec)
[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix-core ---
[INFO] 
[INFO] --- maven-checkstyle-plugin:2.13:check (validate) @ phoenix-core ---
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-source (add-test-source) @ 
phoenix-core ---
[INFO] Test Source directory: 

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

 added.
[INFO] Source directory: 

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

ANTLR Parser Generator  Version 3.5.2
Output file 

 does not exist: must build 

PhoenixSQL.g
[INFO] 
[INFO] --- maven-dependency-plugin:2.1:build-classpath 
(create-phoenix-generated-classpath) @ phoenix-core ---
[INFO] Wrote classpath file 
'
[INFO] 
[INFO] --- maven-remote-resources-plugin:1.5:process (default) @ phoenix-core 
---
[INFO] 
[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ 
phoenix-core ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource to META-INF/services
[INFO] Copying 3 resources
[INFO] 
[INFO] --- maven-compiler-plugin:3.0:compile (default-compile) @ phoenix-core 
---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 951

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

2016-08-17 Thread Apache Jenkins Server

See 

Changes:

[tdsilva] PHOENIX-2995 Write performance severely degrades with large number of

--
[...truncated 997 lines...]
2348/2748 KB   
2350/2748 KB   
2352/2748 KB   
2356/2748 KB   
2357/2748 KB   
2360/2748 KB   
2364/2748 KB   
2365/2748 KB   
2368/2748 KB   
2372/2748 KB   
2373/2748 KB   
2376/2748 KB   
2380/2748 KB   
2381/2748 KB   
2384/2748 KB   
2388/2748 KB   
2389/2748 KB   
2392/2748 KB   
2396/2748 KB   
2400/2748 KB   
2400/2748 KB   
2404/2748 KB   
2408/2748 KB   
2408/2748 KB   
2412/2748 KB   
2416/2748 KB   
2416/2748 KB   
2420/2748 KB   
2424/2748 KB   
2424/2748 KB   
2428/2748 KB   
2432/2748 KB   
2432/2748 KB   
2436/2748 KB   
2440/2748 KB   
2440/2748 KB   
2443/2748 KB   
2447/2748 KB   
2448/2748 KB   
2451/2748 KB   
2455/2748 KB   
2456/2748 KB   
2459/2748 KB   
2463/2748 KB   
2464/2748 KB   
2467/2748 KB   
2471/2748 KB   
2472/2748 KB   
2475/2748 KB   
2479/2748 KB   
2480/2748 KB   
2482/2748 KB   
2486/2748 KB   
2488/2748 KB   
2490/2748 KB   
2494/2748 KB   
2496/2748 KB   
2498/2748 KB   
2502/2748 KB   
2504/2748 KB   
2506/2748 KB   
2510/2748 KB   
2512/2748 KB   
2514/2748 KB   
2518/2748 KB   
2520/2748 KB   
2521/2748 KB   
2525/2748 KB   
2528/2748 KB   
2529/2748 KB   
2533/2748 KB   
2536/2748 KB   
2537/2748 KB   
2541/2748 KB   
2544/2748 KB   
2545/2748 KB   
2549/2748 KB   
2552/2748 KB   
2553/2748 KB   
2557/2748 KB   
2560/2748 KB   
2561/2748 KB   
2565/2748 KB   
2568/2748 KB   
2568/2748 KB   
2572/2748 KB   
2576/2748 KB   
2576/2748 KB   
2580/2748 KB   
2584/2748 KB   
2584/2748 KB   
2588/2748 KB   
2592/2748 KB   
2592/2748 KB   
2596/2748 KB   
2600/2748 KB   
2600/2748 KB   
2604/2748 KB   
2607/2748 KB   
2608/2748 KB   
2612/2748 KB   
2615/2748 KB   
2616/2748 KB   
2620/2748 KB   
2623/2748 KB   
2624/2748 KB   
2628/2748 KB   
2631/2748 KB   
2632/2748 KB   
2636/2748 KB   
2639/2748 KB   
2640/2748 KB   
2644/2748 KB   
2646/2748 KB   
2648/2748 KB   
2652/2748 KB   
2654/2748 KB   
2656/2748 KB   
2660/2748 KB   
2662/2748 KB   
2664/2748 KB   
2668/2748 KB   
2670/2748 KB   
2672/2748 KB   
2676/2748 KB   
2678/2748 KB   
2680/2748 KB   
2684/2748 KB   
2686/2748 KB   
2688/2748 KB   
2692/2748 KB   
2693/2748 KB   
2696/2748 KB   
2700/2748 KB   
2701/2748 KB   
2704/2748 KB   
2708/2748 KB   
2709/2748 KB   
2712/2748 KB   
2716/2748 KB   
2717/2748 KB   
2720/2748 KB   
2724/2748 KB   
2725/2748 KB   
2728/2748 KB   
2732/2748 KB   
2736/2748 KB   
2736/2748 KB   
2740/2748 KB   
2744/2748 KB   
2744/2748 KB   
2748/2748 KB   
2748/2748 KB   
   
Downloaded: 
https://repository.apache.org/content/repositories/releases/org/apache/hbase/hbase-it/1.1.3/hbase-it-1.1.3-tests.jar
 (2748 KB at 1979.7 KB/sec)
[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix-core ---
[INFO] 
[INFO] --- maven-checkstyle-plugin:2.13:check (validate) @ phoenix-core ---
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-source (add-test-source) @ 
phoenix-core ---
[INFO] Test Source directory: 

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

 added.
[INFO] Source directory: 

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

ANTLR Parser Generator  Version 3.5.2
Output file 

 does not exist: must build 

PhoenixSQL.g
[INFO] 
[INFO] --- maven-dependency-plugin:2.1:build-classpath 
(create-phoenix-generated-classpath) @ phoenix-core ---
[INFO] Wrote classpath file 
'
[INFO] 
[INFO] --- maven-remote-resources-plugin:1.5:process (default) @ phoenix-core 
---
[INFO] 
[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ 
phoenix-core ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource to META-INF/services
[INFO] Copying 3 resources
[INFO] 
[INFO] --- maven-compiler-plugin:3.0:compile (default-compile) @ phoenix-core 
---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 951 source

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/master 657917bfb -> 3130fa991


http://git-wip-us.apache.org/repos/asf/phoenix/blob/3130fa99/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 0e044b9..04882e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -64,9 +64,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3130fa99/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+addToTable(metaData,

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/master
Commit: 3130fa9919ba937d98853f9be8068a0a8a8a96f5
Parents: 657917b
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:16:52 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  57 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 371 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/3130fa99/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3130fa99/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.2 116231d10 -> fb21cc5fc


http://git-wip-us.apache.org/repos/asf/phoenix/blob/fb21cc5f/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 0e044b9..04882e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -64,9 +64,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/fb21cc5f/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/4.8-HBase-1.0
Commit: 419ac3f2f1e249b1c2c69ea0b484500ae95eee66
Parents: 6f2d222
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:14:41 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  57 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 371 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/419ac3f2/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/419ac3f2/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/4.x-HBase-1.0
Commit: c22020a479ac39208616d647fbae339cb3fdb1b4
Parents: 24e670d
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:14:04 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  57 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 371 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c22020a4/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c22020a4/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/4.8-HBase-1.1
Commit: ad66cf931c131674fb904a4c20db2101c9bf1187
Parents: c5e1cc0
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:15:01 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  57 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 371 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/ad66cf93/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/ad66cf93/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/4.x-HBase-1.1
Commit: 94b71e7de6b4d4656712bcb166fe827f03799ea5
Parents: c6074b8
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:14:23 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  57 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 371 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/94b71e7d/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/94b71e7d/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 25e79e2920384a47e51b6c62b2b009a67a2e713d
Parents: 6d4e5e0
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:13:05 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  59 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 373 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/25e79e29/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/25e79e29/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.1 c5e1cc077 -> ad66cf931


http://git-wip-us.apache.org/repos/asf/phoenix/blob/ad66cf93/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 0e044b9..04882e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -64,9 +64,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/ad66cf93/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-1.0 6f2d2220c -> 419ac3f2f


http://git-wip-us.apache.org/repos/asf/phoenix/blob/419ac3f2/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 2425033..6241c3a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -65,9 +65,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/419ac3f2/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 6d4e5e0ef -> 25e79e292


http://git-wip-us.apache.org/repos/asf/phoenix/blob/25e79e29/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 0e044b9..04882e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -64,9 +64,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/25e79e29/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 24e670d71 -> c22020a47


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c22020a4/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 2425033..6241c3a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -65,9 +65,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c22020a4/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 c6074b8e8 -> 94b71e7de


http://git-wip-us.apache.org/repos/asf/phoenix/blob/94b71e7d/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 0e044b9..04882e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -64,9 +64,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/94b71e7d/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

PHOENIX-2995 Write performance severely degrades with large number of views


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

Branch: refs/heads/4.8-HBase-0.98
Commit: 304bdab0664f451948a407286d5206099ebd2d6a
Parents: 6efbf40
Author: Thomas D'Silva 
Authored: Fri Jul 22 14:24:38 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Aug 17 11:14:55 2016 -0700

--
 .../apache/phoenix/end2end/UpsertSelectIT.java  |   2 +-
 .../phoenix/compile/CreateTableCompiler.java|   7 +-
 .../apache/phoenix/execute/MutationState.java   | 328 ---
 .../apache/phoenix/jdbc/PhoenixConnection.java  |  59 ++--
 .../query/ConnectionQueryServicesImpl.java  |  93 +++---
 .../query/ConnectionlessQueryServicesImpl.java  |  47 ++-
 .../query/DelegateConnectionQueryServices.java  |  38 +--
 .../apache/phoenix/query/MetaDataMutated.java   |  19 +-
 .../org/apache/phoenix/schema/PMetaData.java|   4 +-
 .../apache/phoenix/schema/PMetaDataImpl.java| 107 +++---
 .../phoenix/schema/PSynchronizedMetaData.java   | 249 ++
 .../apache/phoenix/util/TransactionUtil.java|   4 +-
 .../phoenix/schema/PMetaDataImplTest.java   |  68 ++--
 13 files changed, 652 insertions(+), 373 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/304bdab0/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
index 30de4de..4d811a4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/UpsertSelectIT.java
@@ -1022,7 +1022,7 @@ public class UpsertSelectIT extends 
BaseClientManagedTimeIT {
 // Upsert data with scn set on the connection. The timestamp of 
the put will be the value of the row_timestamp column.
 long rowTimestamp1 = 100;
 Date rowTimestampDate = new Date(rowTimestamp1);
-try (Connection conn = getConnection(ts)) {
+try (Connection conn = getConnection(ts+1)) {
 PreparedStatement stmt = conn.prepareStatement("UPSERT INTO  " 
+ tableName + " (PK1, PK2, PK3, KV1) VALUES(?, ?, ?, ?)");
 stmt.setInt(1, 1);
 stmt.setDate(2, rowTimestampDate);

http://git-wip-us.apache.org/repos/asf/phoenix/blob/304bdab0/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
index b545156..3928f66 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/compile/CreateTableCompiler.java
@@ -54,7 +54,6 @@ import org.apache.phoenix.query.QueryConstants;
 import org.apache.phoenix.schema.ColumnRef;
 import org.apache.phoenix.schema.MetaDataClient;
 import org.apache.phoenix.schema.PDatum;
-import org.apache.phoenix.schema.PMetaData;
 import org.apache.phoenix.schema.PTable;
 import org.apache.phoenix.schema.PTable.ViewType;
 import org.apache.phoenix.schema.PTableType;
@@ -143,11 +142,11 @@ public class CreateTableCompiler {
 // on our connection.
 new 
DelegateConnectionQueryServices(connection.getQueryServices()) {
 @Override
-public PMetaData addTable(PTable table, long 
resolvedTime) throws SQLException {
-return connection.addTable(table, 
resolvedTime);
+public void addTable(PTable table, long 
resolvedTime) throws SQLException {
+connection.addTable(table, resolvedTime);
 }
 },
-connection, tableRef.getTimeStamp());
+connection, tableRef.getTimeStamp()+1);
 viewColumnConstantsToBe = new byte[nColumns][];
 ViewWhereExpressionVisitor visitor = new 
ViewWhereExpressionVisitor(parentToBe, viewColumnConstantsToBe);
 where.accept(visitor);

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

2016-08-17 Thread tdsilva

Repository: phoenix
Updated Branches:
  refs/heads/4.8-HBase-0.98 6efbf404e -> 304bdab06


http://git-wip-us.apache.org/repos/asf/phoenix/blob/304bdab0/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java 
b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
index 0e044b9..04882e0 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/util/TransactionUtil.java
@@ -64,9 +64,9 @@ public class TransactionUtil {
 .build().buildException();
 }
 
-public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, PTable table) {
+public static TransactionAwareHTable 
getTransactionAwareHTable(HTableInterface htable, boolean isImmutableRows) {
// Conflict detection is not needed for tables with 
write-once/append-only data
-   return new TransactionAwareHTable(htable, table.isImmutableRows() ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
+   return new TransactionAwareHTable(htable, isImmutableRows ? 
TxConstants.ConflictDetection.NONE : TxConstants.ConflictDetection.ROW);
 }
 
 // we resolve transactional tables at the txn read pointer

http://git-wip-us.apache.org/repos/asf/phoenix/blob/304bdab0/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
--
diff --git 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
index 9c92679..ef88c8c 100644
--- 
a/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
+++ 
b/phoenix-core/src/test/java/org/apache/phoenix/schema/PMetaDataImplTest.java
@@ -31,17 +31,15 @@ import com.google.common.collect.Sets;
 
 public class PMetaDataImplTest {
 
-private static PMetaData addToTable(PMetaData metaData, String name, int 
size, TestTimeKeeper timeKeeper) throws SQLException {
+private static void addToTable(PMetaData metaData, String name, int size, 
TestTimeKeeper timeKeeper) throws SQLException {
 PTable table = new PSizedTable(new PTableKey(null,name), size);
-PMetaData newMetaData = metaData.addTable(table, 
System.currentTimeMillis());
+metaData.addTable(table, System.currentTimeMillis());
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
-private static PMetaData removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
-PMetaData newMetaData =  metaData.removeTable(null, name, null, 
HConstants.LATEST_TIMESTAMP);
+private static void removeFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws SQLException {
+metaData.removeTable(null, name, null, HConstants.LATEST_TIMESTAMP);
 timeKeeper.incrementTime();
-return newMetaData;
 }
 
 private static PTable getFromTable(PMetaData metaData, String name, 
TestTimeKeeper timeKeeper) throws TableNotFoundException {
@@ -77,41 +75,41 @@ public class PMetaDataImplTest {
 long maxSize = 10;
 TestTimeKeeper timeKeeper = new TestTimeKeeper();
 PMetaData metaData = new PMetaDataImpl(5, maxSize, timeKeeper);
-metaData = addToTable(metaData, "a", 5, timeKeeper);
+addToTable(metaData, "a", 5, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 4, timeKeeper);
+addToTable(metaData, "b", 4, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 3, timeKeeper);
+addToTable(metaData, "c", 3, timeKeeper);
 assertEquals(2, metaData.size());
 assertNames(metaData, "b","c");
 
-metaData = addToTable(metaData, "b", 8, timeKeeper);
+addToTable(metaData, "b", 8, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "b");
 
-metaData = addToTable(metaData, "d", 11, timeKeeper);
+addToTable(metaData, "d", 11, timeKeeper);
 assertEquals(1, metaData.size());
 assertNames(metaData, "d");
 
-metaData = removeFromTable(metaData, "d", timeKeeper);
+removeFromTable(metaData, "d", timeKeeper);
 assertNames(metaData);
 
-metaData = addToTable(metaData, "a", 4, timeKeeper);
+addToTable(metaData, "a", 4, timeKeeper);
 assertEquals(1, metaData.size());
-metaData = addToTable(metaData, "b", 3, timeKeeper);
+addToTable(metaData, "b", 3, timeKeeper);
 assertEquals(2, metaData.size());
-metaData = addToTable(metaData, "c", 2, timeKeeper);
+

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #24

2016-08-17 Thread Apache Jenkins Server

See 

--
Started by timer
[EnvInject] - Loading node environment variables.
Building remotely on H10 (Ubuntu yahoo-not-h2 ubuntu docker) in workspace 

[Phoenix_Compile_Compat_wHBase] $ /bin/bash /tmp/hudson6340593489234792355.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) 386178
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 : 10
core id : 9
physical id : 0
physical id : 1
MemTotal:   49453340 kB
MemFree: 6699880 kB
Filesystem  Size  Used Avail Use% Mounted on
udev 24G   12K   24G   1% /dev
tmpfs   4.8G  776K  4.8G   1% /run
/dev/dm-0   3.6T  789G  2.6T  23% /
none4.0K 0  4.0K   0% /sys/fs/cgroup
none5.0M 0  5.0M   0% /run/lock
none 24G 0   24G   0% /run/shm
none100M 0  100M   0% /run/user
/dev/sda2   237M  114M  111M  51% /boot
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
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.21
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.2 with Phoenix master

svn commit: r1756700 - in /phoenix/site: publish/index.html publish/news.html source/src/site/markdown/index.md source/src/site/markdown/news.md

svn commit: r1756695 - in /phoenix: phoenix-docs/src/docsrc/help/ site/publish/ site/publish/language/ site/source/src/site/markdown/

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

Jenkins build is back to normal : Phoenix | Master #1364

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

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

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views (addendum)

Build failed in Jenkins: Phoenix | Master #1363

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

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

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[2/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

[1/2] phoenix git commit: PHOENIX-2995 Write performance severely degrades with large number of views

Build failed in Jenkins: Phoenix Compile Level Compatibility with HBase #24

30 matches

Site Navigation

Mail list logo

Footer information