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

2016-06-29 Thread Apache Jenkins Server 
See 

--
[...truncated 2081 lines...]
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.UserDefinedFunctionsIT.doSetup(UserDefinedFunctionsIT.java:249)

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

Running org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.007 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT  Time elapsed: 0.006 
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
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)

Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.605 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexFailureIT
org.apache.phoenix.end2end.index.MutableIndexFailureIT  Time elapsed: 0.605 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.ReadOnlyIndexFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.009 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT  Time elapsed: 0.008 
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: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT.doSetup(TxWriteFailureIT.java:86)
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds

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

2016-06-29 Thread Apache Jenkins Server 
See 

Changes:

[tdsilva] PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA

--
[...truncated 2081 lines...]
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.UserDefinedFunctionsIT.doSetup(UserDefinedFunctionsIT.java:249)

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

Running org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.006 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT  Time elapsed: 0.005 
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
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.MutableIndexFailureIT
org.apache.phoenix.end2end.index.MutableIndexFailureIT  Time elapsed: 0.005 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)

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.hbase.index.FailForUnsupportedHBaseVersionsIT
Running org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.006 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.006 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.txn.TxWriteFailureIT
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT  Time elapsed: 0.005 sec  
<<< ERROR!
java.lang.RuntimeException: java.io.IOException: Shutting down
at 
org.apache.phoenix.end2end.index.txn.TxWriteFailureIT.doSetup(TxWriteFailureIT.java:86)
Caused by: java.io.IOException: Shutting down
at

Build failed in Jenkins: Phoenix | Master #1301

2016-06-29 Thread Apache Jenkins Server 
See 

Changes:

[tdsilva] PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA

--
[...truncated 732 lines...]
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 642.622 sec - 
in org.apache.phoenix.end2end.index.LocalIndexIT
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 158.926 sec - 
in org.apache.phoenix.tx.TxCheckpointIT
Tests run: 21, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 266.37 sec - 
in org.apache.phoenix.tx.TransactionIT
Tests run: 40, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 872.773 sec - 
in org.apache.phoenix.end2end.index.MutableIndexIT

Results :

Tests run: 1193, 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: 2.809 sec - in 
org.apache.phoenix.end2end.AbsFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ArraysWithNullsIT
Running org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.AlterSessionIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.102 sec - in 
org.apache.phoenix.end2end.AlterSessionIT
Running org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.451 sec - in 
org.apache.phoenix.end2end.AutoCommitIT
Running org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.508 sec - in 
org.apache.phoenix.end2end.CbrtFunctionEnd2EndIT
Running org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 21.293 sec - 
in org.apache.phoenix.end2end.ArrayFillFunctionIT
Running org.apache.phoenix.end2end.DecodeFunctionIT
Tests run: 36, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 27.3 sec - in 
org.apache.phoenix.end2end.ArrayToStringFunctionIT
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.054 sec - in 
org.apache.phoenix.end2end.DecodeFunctionIT
Running org.apache.phoenix.end2end.DynamicFamilyIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 20.765 sec - in 
org.apache.phoenix.end2end.ConvertTimezoneFunctionIT
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.944 sec - in 
org.apache.phoenix.end2end.DynamicFamilyIT
Running org.apache.phoenix.end2end.DynamicUpsertIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.119 sec - in 
org.apache.phoenix.end2end.DynamicUpsertIT
Running org.apache.phoenix.end2end.FirstValueFunctionIT
Tests run: 16, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 47.998 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.146 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: 4.889 sec - in 
org.apache.phoenix.end2end.LikeExpressionIT
Running org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.123 sec - in 
org.apache.phoenix.end2end.MD5FunctionIT
Running org.apache.phoenix.end2end.DistinctPrefixFilterIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.536 sec - in 
org.apache.phoenix.end2end.MinMaxAggregateFunctionIT
Running org.apache.phoenix.end2end.NthValueFunctionIT
Running org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.44 sec - in 
org.apache.phoenix.end2end.OctetLengthFunctionEnd2EndIT
Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 20.826 sec - in 
org.apache.phoenix.end2end.FirstValueFunctionIT
Running org.apache.phoenix.end2end.PrimitiveTypeIT
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.215 sec - in 
org.apache.phoenix.end2end.PrimitiveTypeIT
Running org.apache.phoenix.end2end.QueryMoreIT
Running org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.573 sec - in 
org.apache.phoenix.end2end.PowerFunctionEnd2EndIT
Running org.apache.phoenix.end2end.RTrimFunctionIT
Tests run: 26, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 73.402 sec - 
in org.apache.phoenix.end2end.ArithmeticQueryIT
Running org.apache.phoenix.end2end.ReadOnlyIT
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time

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

2016-06-29 Thread Apache Jenkins Server 
4.x-HBase-1.0 branch build status Successful

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

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

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

Changes
[tdsilva] PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA



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-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA

2016-06-29 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 4a728fb57 -> 736cf83a4


PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA


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

Branch: refs/heads/4.x-HBase-1.0
Commit: 736cf83a478ad1247240f672df9bf2b7bb09f5e6
Parents: 4a728fb
Author: Thomas D'Silva 
Authored: Tue Jun 28 20:14:47 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Jun 29 10:33:58 2016 -0700

--
 .../phoenix/end2end/AppendOnlySchemaIT.java | 52 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 68 +++-
 2 files changed, 74 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/736cf83a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
index bc427b6..080ccad 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
@@ -27,17 +27,19 @@ import static org.mockito.Matchers.anyList;
 import static org.mockito.Matchers.anyListOf;
 import static org.mockito.Matchers.anyLong;
 import static org.mockito.Matchers.anyMap;
+import static org.mockito.Matchers.anySetOf;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Matchers.isNull;
-import static org.mockito.Mockito.atMost;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.reset;
+import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.util.Collections;
 import java.util.List;
 import java.util.Properties;
 
@@ -47,6 +49,7 @@ import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.jdbc.PhoenixConnection;
 import org.apache.phoenix.jdbc.PhoenixEmbeddedDriver;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.schema.ColumnAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
 import org.apache.phoenix.schema.PName;
 import org.apache.phoenix.schema.PTable;
@@ -59,7 +62,7 @@ import org.mockito.Mockito;
 
 public class AppendOnlySchemaIT extends BaseHBaseManagedTimeIT {
 
-private void createTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
+private void testTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
 // use a spyed ConnectionQueryServices so we can verify calls to 
getTable
 ConnectionQueryServices connectionQueryServices =
 Mockito.spy(driver.getConnectionQueryServices(getUrl(),
@@ -77,7 +80,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 // create view
 String ddl =
 "CREATE VIEW " + (notExists ? "IF NOT EXISTS" : "")
-+ " view1( hostName varchar NOT NULL,"
++ " view1( hostName varchar NOT NULL, tagName 
varChar"
 + " CONSTRAINT HOSTNAME_PK PRIMARY KEY (hostName))"
 + " AS SELECT * FROM metric_table"
 + " APPEND_ONLY_SCHEMA = true, 
UPDATE_CACHE_FREQUENCY=30";
@@ -86,7 +89,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 conn1.commit();
 reset(connectionQueryServices);
 
-// execute same ddl
+// execute same create ddl
 try {
 conn2.createStatement().execute(ddl);
 if (!notExists) {
@@ -100,12 +103,31 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 }
 
 // verify getTable rpcs
-verify(connectionQueryServices, sameClient ? never() : 
atMost(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
+verify(connectionQueryServices, sameClient ? never() : 
times(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
 
-// verify create table rpcs
+// verify no create table rpcs
 verify(connectionQueryServices, 
never()).createTable(anyListOf(Mutation.class),

phoenix git commit: PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA

2016-06-29 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.1 422bca2fb -> 1d29ec0b6


PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA


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

Branch: refs/heads/4.x-HBase-1.1
Commit: 1d29ec0b66daa8a9b5d0067ff69c6f707013dc8a
Parents: 422bca2
Author: Thomas D'Silva 
Authored: Tue Jun 28 20:14:47 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Jun 29 10:33:37 2016 -0700

--
 .../phoenix/end2end/AppendOnlySchemaIT.java | 52 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 68 +++-
 2 files changed, 74 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/1d29ec0b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
index bc427b6..080ccad 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
@@ -27,17 +27,19 @@ import static org.mockito.Matchers.anyList;
 import static org.mockito.Matchers.anyListOf;
 import static org.mockito.Matchers.anyLong;
 import static org.mockito.Matchers.anyMap;
+import static org.mockito.Matchers.anySetOf;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Matchers.isNull;
-import static org.mockito.Mockito.atMost;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.reset;
+import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.util.Collections;
 import java.util.List;
 import java.util.Properties;
 
@@ -47,6 +49,7 @@ import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.jdbc.PhoenixConnection;
 import org.apache.phoenix.jdbc.PhoenixEmbeddedDriver;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.schema.ColumnAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
 import org.apache.phoenix.schema.PName;
 import org.apache.phoenix.schema.PTable;
@@ -59,7 +62,7 @@ import org.mockito.Mockito;
 
 public class AppendOnlySchemaIT extends BaseHBaseManagedTimeIT {
 
-private void createTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
+private void testTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
 // use a spyed ConnectionQueryServices so we can verify calls to 
getTable
 ConnectionQueryServices connectionQueryServices =
 Mockito.spy(driver.getConnectionQueryServices(getUrl(),
@@ -77,7 +80,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 // create view
 String ddl =
 "CREATE VIEW " + (notExists ? "IF NOT EXISTS" : "")
-+ " view1( hostName varchar NOT NULL,"
++ " view1( hostName varchar NOT NULL, tagName 
varChar"
 + " CONSTRAINT HOSTNAME_PK PRIMARY KEY (hostName))"
 + " AS SELECT * FROM metric_table"
 + " APPEND_ONLY_SCHEMA = true, 
UPDATE_CACHE_FREQUENCY=30";
@@ -86,7 +89,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 conn1.commit();
 reset(connectionQueryServices);
 
-// execute same ddl
+// execute same create ddl
 try {
 conn2.createStatement().execute(ddl);
 if (!notExists) {
@@ -100,12 +103,31 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 }
 
 // verify getTable rpcs
-verify(connectionQueryServices, sameClient ? never() : 
atMost(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
+verify(connectionQueryServices, sameClient ? never() : 
times(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
 
-// verify create table rpcs
+// verify no create table rpcs
 verify(connectionQueryServices, 
never()).createTable(anyListOf(Mutation.class),

phoenix git commit: PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA

2016-06-29 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/master bbfb1e319 -> d1cde87fa


PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA


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

Branch: refs/heads/master
Commit: d1cde87fadf77eb9aa12ed07a53516725f5db307
Parents: bbfb1e3
Author: Thomas D'Silva 
Authored: Tue Jun 28 20:14:47 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Jun 29 10:33:18 2016 -0700

--
 .../phoenix/end2end/AppendOnlySchemaIT.java | 52 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 68 +++-
 2 files changed, 74 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/d1cde87f/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
index bc427b6..080ccad 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
@@ -27,17 +27,19 @@ import static org.mockito.Matchers.anyList;
 import static org.mockito.Matchers.anyListOf;
 import static org.mockito.Matchers.anyLong;
 import static org.mockito.Matchers.anyMap;
+import static org.mockito.Matchers.anySetOf;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Matchers.isNull;
-import static org.mockito.Mockito.atMost;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.reset;
+import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.util.Collections;
 import java.util.List;
 import java.util.Properties;
 
@@ -47,6 +49,7 @@ import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.jdbc.PhoenixConnection;
 import org.apache.phoenix.jdbc.PhoenixEmbeddedDriver;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.schema.ColumnAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
 import org.apache.phoenix.schema.PName;
 import org.apache.phoenix.schema.PTable;
@@ -59,7 +62,7 @@ import org.mockito.Mockito;
 
 public class AppendOnlySchemaIT extends BaseHBaseManagedTimeIT {
 
-private void createTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
+private void testTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
 // use a spyed ConnectionQueryServices so we can verify calls to 
getTable
 ConnectionQueryServices connectionQueryServices =
 Mockito.spy(driver.getConnectionQueryServices(getUrl(),
@@ -77,7 +80,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 // create view
 String ddl =
 "CREATE VIEW " + (notExists ? "IF NOT EXISTS" : "")
-+ " view1( hostName varchar NOT NULL,"
++ " view1( hostName varchar NOT NULL, tagName 
varChar"
 + " CONSTRAINT HOSTNAME_PK PRIMARY KEY (hostName))"
 + " AS SELECT * FROM metric_table"
 + " APPEND_ONLY_SCHEMA = true, 
UPDATE_CACHE_FREQUENCY=30";
@@ -86,7 +89,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 conn1.commit();
 reset(connectionQueryServices);
 
-// execute same ddl
+// execute same create ddl
 try {
 conn2.createStatement().execute(ddl);
 if (!notExists) {
@@ -100,12 +103,31 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 }
 
 // verify getTable rpcs
-verify(connectionQueryServices, sameClient ? never() : 
atMost(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
+verify(connectionQueryServices, sameClient ? never() : 
times(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
 
-// verify create table rpcs
+// verify no create table rpcs
 verify(connectionQueryServices, 
never()).createTable(anyListOf(Mutation.class),

phoenix git commit: PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA

2016-06-29 Thread tdsilva 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 f7ff1aefd -> 34662a314


PHOENIX-2968 Minimize RPCs for ALTER statement over APPEND_ONLY_SCHEMA


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 34662a314ac011629aa043042cef8ea91ca972c2
Parents: f7ff1ae
Author: Thomas D'Silva 
Authored: Tue Jun 28 20:14:47 2016 -0700
Committer: Thomas D'Silva 
Committed: Wed Jun 29 10:34:21 2016 -0700

--
 .../phoenix/end2end/AppendOnlySchemaIT.java | 52 ++-
 .../apache/phoenix/schema/MetaDataClient.java   | 68 +++-
 2 files changed, 74 insertions(+), 46 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/34662a31/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
index bc427b6..080ccad 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AppendOnlySchemaIT.java
@@ -27,17 +27,19 @@ import static org.mockito.Matchers.anyList;
 import static org.mockito.Matchers.anyListOf;
 import static org.mockito.Matchers.anyLong;
 import static org.mockito.Matchers.anyMap;
+import static org.mockito.Matchers.anySetOf;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Matchers.isNull;
-import static org.mockito.Mockito.atMost;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.reset;
+import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.util.Collections;
 import java.util.List;
 import java.util.Properties;
 
@@ -47,6 +49,7 @@ import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.jdbc.PhoenixConnection;
 import org.apache.phoenix.jdbc.PhoenixEmbeddedDriver;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.schema.ColumnAlreadyExistsException;
 import org.apache.phoenix.schema.PColumn;
 import org.apache.phoenix.schema.PName;
 import org.apache.phoenix.schema.PTable;
@@ -59,7 +62,7 @@ import org.mockito.Mockito;
 
 public class AppendOnlySchemaIT extends BaseHBaseManagedTimeIT {
 
-private void createTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
+private void testTableWithSameSchema(boolean notExists, boolean 
sameClient) throws Exception {
 // use a spyed ConnectionQueryServices so we can verify calls to 
getTable
 ConnectionQueryServices connectionQueryServices =
 Mockito.spy(driver.getConnectionQueryServices(getUrl(),
@@ -77,7 +80,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 // create view
 String ddl =
 "CREATE VIEW " + (notExists ? "IF NOT EXISTS" : "")
-+ " view1( hostName varchar NOT NULL,"
++ " view1( hostName varchar NOT NULL, tagName 
varChar"
 + " CONSTRAINT HOSTNAME_PK PRIMARY KEY (hostName))"
 + " AS SELECT * FROM metric_table"
 + " APPEND_ONLY_SCHEMA = true, 
UPDATE_CACHE_FREQUENCY=30";
@@ -86,7 +89,7 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 conn1.commit();
 reset(connectionQueryServices);
 
-// execute same ddl
+// execute same create ddl
 try {
 conn2.createStatement().execute(ddl);
 if (!notExists) {
@@ -100,12 +103,31 @@ public class AppendOnlySchemaIT extends 
BaseHBaseManagedTimeIT {
 }
 
 // verify getTable rpcs
-verify(connectionQueryServices, sameClient ? never() : 
atMost(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
+verify(connectionQueryServices, sameClient ? never() : 
times(1)).getTable((PName)isNull(), eq(new byte[0]), 
eq(Bytes.toBytes("VIEW1")), anyLong(), anyLong());
 
-// verify create table rpcs
+// verify no create table rpcs
 verify(connectionQueryServices, 
never()).createTable(anyListOf(Mutation.class),

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

2016-06-29 Thread Apache Jenkins Server 
4.x-HBase-1.0 branch build status Successful

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

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

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

Changes
[elserj] PHOENIX-2931 Phoenix client asks users to provide configs in cli that



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

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

2016-06-29 Thread Apache Jenkins Server 
See

Jenkins build is back to normal : Phoenix-4.x-HBase-1.1 #95

2016-06-29 Thread Apache Jenkins Server 
See

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

2016-06-29 Thread Apache Jenkins Server 
4.x-HBase-1.0 branch build status Successful

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

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

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

Changes
[rajeshbabu] PHOENIX-3018 Write local updates to region than HTable in master



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

[4/4] phoenix git commit: PHOENIX-2931 Phoenix client asks users to provide configs in cli that are present on the machine in hbase conf (aliciashu)

2016-06-29 Thread elserj 
PHOENIX-2931 Phoenix client asks users to provide configs in cli that are 
present on the machine in hbase conf (aliciashu)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: f7ff1aefdd032322cfd95907c53b5d9625bceffc
Parents: 48f4a9e
Author: Josh Elser 
Authored: Tue Jun 28 23:29:52 2016 -0700
Committer: Josh Elser 
Committed: Tue Jun 28 23:38:10 2016 -0700

--
 bin/sqlline.py  | 37 +++-
 .../phoenix/jdbc/PhoenixEmbeddedDriver.java | 28 +++
 .../org/apache/phoenix/util/PhoenixRuntime.java | 16 +++--
 .../phoenix/jdbc/PhoenixEmbeddedDriverTest.java |  6 ++--
 4 files changed, 72 insertions(+), 15 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/f7ff1aef/bin/sqlline.py
--
diff --git a/bin/sqlline.py b/bin/sqlline.py
index 6d537e3..474968f 100755
--- a/bin/sqlline.py
+++ b/bin/sqlline.py
@@ -37,21 +37,40 @@ atexit.register(kill_child)
 
 phoenix_utils.setPath()
 
-if len(sys.argv) < 2:
-print "Zookeeper not specified. \nUsage: sqlline.py  \
- \nExample: \n 1. sqlline.py localhost:2181:/hbase \n 2. 
sqlline.py \
-localhost:2181:/hbase ../examples/stock_symbol.sql"
-sys.exit()
+def printUsage():
+print "\nUsage: sqlline.py [zookeeper] \
+[optional_sql_file] \nExample: \n 1. sqlline.py \n \
+2. sqlline.py localhost:2181:/hbase \n 3. sqlline.py \
+localhost:2181:/hbase ../examples/stock_symbol.sql \n \
+4. sqlline.py ../examples/stock_symbol.sql"
+sys.exit(-1)
 
-sqlfile = ""
+if len(sys.argv) > 3:
+printUsage()
 
-if len(sys.argv) > 2:
-sqlfile = "--run=" + phoenix_utils.shell_quote([sys.argv[2]])
+sqlfile = ""
+zookeeper = ""
 
 # HBase configuration folder path (where hbase-site.xml reside) for
 # HBase/Phoenix client side property override
 hbase_config_path = os.getenv('HBASE_CONF_DIR', phoenix_utils.current_dir)
 
+if len(sys.argv) == 2:
+if os.path.isfile(sys.argv[1]):
+sqlfile = sys.argv[1]
+else:
+zookeeper = sys.argv[1]
+
+if len(sys.argv) == 3:
+if os.path.isfile(sys.argv[1]):
+printUsage()
+else:
+zookeeper = sys.argv[1]
+sqlfile = sys.argv[2]
+
+if sqlfile:
+sqlfile = "--run=" + phoenix_utils.shell_quote([sqlfile])
+
 java_home = os.getenv('JAVA_HOME')
 
 # load hbase-env.??? to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR
@@ -92,7 +111,7 @@ java_cmd = java + ' $PHOENIX_OPTS ' + \
 os.pathsep + phoenix_utils.hadoop_conf + os.pathsep + 
phoenix_utils.hadoop_classpath + '" -Dlog4j.configuration=file:' + \
 os.path.join(phoenix_utils.current_dir, "log4j.properties") + \
 " sqlline.SqlLine -d org.apache.phoenix.jdbc.PhoenixDriver \
--u jdbc:phoenix:" + phoenix_utils.shell_quote([sys.argv[1]]) + \
+-u jdbc:phoenix:" + phoenix_utils.shell_quote([zookeeper]) + \
 " -n none -p none --color=" + colorSetting + " --fastConnect=false 
--verbose=true \
 --incremental=false --isolation=TRANSACTION_READ_COMMITTED " + sqlfile
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/f7ff1aef/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
index 7943559..40e03b9 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
@@ -31,13 +31,19 @@ import java.util.logging.Logger;
 
 import javax.annotation.concurrent.Immutable;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HConstants;
 import org.apache.phoenix.coprocessor.MetaDataProtocol;
 import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.exception.SQLExceptionInfo;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.query.HBaseFactoryProvider;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
+import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
 import org.apache.phoenix.util.SQLCloseable;
 
@@ -58,6 +64,7 @@ public abstract class PhoenixEmbeddedDriver implements 
Driver, SQLCloseable {
 /**

[1/4] phoenix git commit: PHOENIX-2931 Phoenix client asks users to provide configs in cli that are present on the machine in hbase conf (aliciashu)

2016-06-29 Thread elserj 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 48f4a9e7e -> f7ff1aefd
  refs/heads/4.x-HBase-1.0 6bfcfe5fa -> 4a728fb57
  refs/heads/4.x-HBase-1.1 5451a6c39 -> 422bca2fb
  refs/heads/master 93e7c1b30 -> bbfb1e319


PHOENIX-2931 Phoenix client asks users to provide configs in cli that are 
present on the machine in hbase conf (aliciashu)


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

Branch: refs/heads/master
Commit: bbfb1e31921db6767c003679715ab2dc6a244423
Parents: 93e7c1b
Author: Josh Elser 
Authored: Tue Jun 28 23:29:52 2016 -0700
Committer: Josh Elser 
Committed: Tue Jun 28 23:29:52 2016 -0700

--
 bin/sqlline.py  | 37 +++-
 .../phoenix/jdbc/PhoenixEmbeddedDriver.java | 28 +++
 .../org/apache/phoenix/util/PhoenixRuntime.java | 16 +++--
 .../phoenix/jdbc/PhoenixEmbeddedDriverTest.java |  6 ++--
 4 files changed, 72 insertions(+), 15 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/bbfb1e31/bin/sqlline.py
--
diff --git a/bin/sqlline.py b/bin/sqlline.py
index 6d537e3..474968f 100755
--- a/bin/sqlline.py
+++ b/bin/sqlline.py
@@ -37,21 +37,40 @@ atexit.register(kill_child)
 
 phoenix_utils.setPath()
 
-if len(sys.argv) < 2:
-print "Zookeeper not specified. \nUsage: sqlline.py  \
- \nExample: \n 1. sqlline.py localhost:2181:/hbase \n 2. 
sqlline.py \
-localhost:2181:/hbase ../examples/stock_symbol.sql"
-sys.exit()
+def printUsage():
+print "\nUsage: sqlline.py [zookeeper] \
+[optional_sql_file] \nExample: \n 1. sqlline.py \n \
+2. sqlline.py localhost:2181:/hbase \n 3. sqlline.py \
+localhost:2181:/hbase ../examples/stock_symbol.sql \n \
+4. sqlline.py ../examples/stock_symbol.sql"
+sys.exit(-1)
 
-sqlfile = ""
+if len(sys.argv) > 3:
+printUsage()
 
-if len(sys.argv) > 2:
-sqlfile = "--run=" + phoenix_utils.shell_quote([sys.argv[2]])
+sqlfile = ""
+zookeeper = ""
 
 # HBase configuration folder path (where hbase-site.xml reside) for
 # HBase/Phoenix client side property override
 hbase_config_path = os.getenv('HBASE_CONF_DIR', phoenix_utils.current_dir)
 
+if len(sys.argv) == 2:
+if os.path.isfile(sys.argv[1]):
+sqlfile = sys.argv[1]
+else:
+zookeeper = sys.argv[1]
+
+if len(sys.argv) == 3:
+if os.path.isfile(sys.argv[1]):
+printUsage()
+else:
+zookeeper = sys.argv[1]
+sqlfile = sys.argv[2]
+
+if sqlfile:
+sqlfile = "--run=" + phoenix_utils.shell_quote([sqlfile])
+
 java_home = os.getenv('JAVA_HOME')
 
 # load hbase-env.??? to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR
@@ -92,7 +111,7 @@ java_cmd = java + ' $PHOENIX_OPTS ' + \
 os.pathsep + phoenix_utils.hadoop_conf + os.pathsep + 
phoenix_utils.hadoop_classpath + '" -Dlog4j.configuration=file:' + \
 os.path.join(phoenix_utils.current_dir, "log4j.properties") + \
 " sqlline.SqlLine -d org.apache.phoenix.jdbc.PhoenixDriver \
--u jdbc:phoenix:" + phoenix_utils.shell_quote([sys.argv[1]]) + \
+-u jdbc:phoenix:" + phoenix_utils.shell_quote([zookeeper]) + \
 " -n none -p none --color=" + colorSetting + " --fastConnect=false 
--verbose=true \
 --incremental=false --isolation=TRANSACTION_READ_COMMITTED " + sqlfile
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/bbfb1e31/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
index 7943559..40e03b9 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
@@ -31,13 +31,19 @@ import java.util.logging.Logger;
 
 import javax.annotation.concurrent.Immutable;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HConstants;
 import org.apache.phoenix.coprocessor.MetaDataProtocol;
 import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.exception.SQLExceptionInfo;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.query.HBaseFactoryProvider;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
+import

[3/4] phoenix git commit: PHOENIX-2931 Phoenix client asks users to provide configs in cli that are present on the machine in hbase conf (aliciashu)

2016-06-29 Thread elserj 
PHOENIX-2931 Phoenix client asks users to provide configs in cli that are 
present on the machine in hbase conf (aliciashu)


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

Branch: refs/heads/4.x-HBase-1.0
Commit: 4a728fb57f633fbfa0f01fc8036f9588ee5b3ee9
Parents: 6bfcfe5
Author: Josh Elser 
Authored: Tue Jun 28 23:29:52 2016 -0700
Committer: Josh Elser 
Committed: Tue Jun 28 23:34:26 2016 -0700

--
 bin/sqlline.py  | 37 +++-
 .../phoenix/jdbc/PhoenixEmbeddedDriver.java | 28 +++
 .../org/apache/phoenix/util/PhoenixRuntime.java | 16 +++--
 .../phoenix/jdbc/PhoenixEmbeddedDriverTest.java |  6 ++--
 4 files changed, 72 insertions(+), 15 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/4a728fb5/bin/sqlline.py
--
diff --git a/bin/sqlline.py b/bin/sqlline.py
index 6d537e3..474968f 100755
--- a/bin/sqlline.py
+++ b/bin/sqlline.py
@@ -37,21 +37,40 @@ atexit.register(kill_child)
 
 phoenix_utils.setPath()
 
-if len(sys.argv) < 2:
-print "Zookeeper not specified. \nUsage: sqlline.py  \
- \nExample: \n 1. sqlline.py localhost:2181:/hbase \n 2. 
sqlline.py \
-localhost:2181:/hbase ../examples/stock_symbol.sql"
-sys.exit()
+def printUsage():
+print "\nUsage: sqlline.py [zookeeper] \
+[optional_sql_file] \nExample: \n 1. sqlline.py \n \
+2. sqlline.py localhost:2181:/hbase \n 3. sqlline.py \
+localhost:2181:/hbase ../examples/stock_symbol.sql \n \
+4. sqlline.py ../examples/stock_symbol.sql"
+sys.exit(-1)
 
-sqlfile = ""
+if len(sys.argv) > 3:
+printUsage()
 
-if len(sys.argv) > 2:
-sqlfile = "--run=" + phoenix_utils.shell_quote([sys.argv[2]])
+sqlfile = ""
+zookeeper = ""
 
 # HBase configuration folder path (where hbase-site.xml reside) for
 # HBase/Phoenix client side property override
 hbase_config_path = os.getenv('HBASE_CONF_DIR', phoenix_utils.current_dir)
 
+if len(sys.argv) == 2:
+if os.path.isfile(sys.argv[1]):
+sqlfile = sys.argv[1]
+else:
+zookeeper = sys.argv[1]
+
+if len(sys.argv) == 3:
+if os.path.isfile(sys.argv[1]):
+printUsage()
+else:
+zookeeper = sys.argv[1]
+sqlfile = sys.argv[2]
+
+if sqlfile:
+sqlfile = "--run=" + phoenix_utils.shell_quote([sqlfile])
+
 java_home = os.getenv('JAVA_HOME')
 
 # load hbase-env.??? to extract JAVA_HOME, HBASE_PID_DIR, HBASE_LOG_DIR
@@ -92,7 +111,7 @@ java_cmd = java + ' $PHOENIX_OPTS ' + \
 os.pathsep + phoenix_utils.hadoop_conf + os.pathsep + 
phoenix_utils.hadoop_classpath + '" -Dlog4j.configuration=file:' + \
 os.path.join(phoenix_utils.current_dir, "log4j.properties") + \
 " sqlline.SqlLine -d org.apache.phoenix.jdbc.PhoenixDriver \
--u jdbc:phoenix:" + phoenix_utils.shell_quote([sys.argv[1]]) + \
+-u jdbc:phoenix:" + phoenix_utils.shell_quote([zookeeper]) + \
 " -n none -p none --color=" + colorSetting + " --fastConnect=false 
--verbose=true \
 --incremental=false --isolation=TRANSACTION_READ_COMMITTED " + sqlfile
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/4a728fb5/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
index 7943559..40e03b9 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/jdbc/PhoenixEmbeddedDriver.java
@@ -31,13 +31,19 @@ import java.util.logging.Logger;
 
 import javax.annotation.concurrent.Immutable;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HConstants;
 import org.apache.phoenix.coprocessor.MetaDataProtocol;
 import org.apache.phoenix.exception.SQLExceptionCode;
 import org.apache.phoenix.exception.SQLExceptionInfo;
 import org.apache.phoenix.query.ConnectionQueryServices;
+import org.apache.phoenix.query.HBaseFactoryProvider;
 import org.apache.phoenix.query.QueryServices;
 import org.apache.phoenix.util.PhoenixRuntime;
 import org.apache.phoenix.util.PropertiesUtil;
+import org.apache.phoenix.util.QueryUtil;
 import org.apache.phoenix.util.ReadOnlyProps;
 import org.apache.phoenix.util.SQLCloseable;
 
@@ -58,6 +64,7 @@ public abstract class PhoenixEmbeddedDriver implements 
Driver, SQLCloseable {
 /**

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

2016-06-29 Thread Apache Jenkins Server 
See 

Changes:

[rajeshbabu] PHOENIX-3018 Write local updates to region than HTable in master

--
[...truncated 2081 lines...]
Caused by: java.lang.RuntimeException: Master not initialized after 20ms 
seconds
at 
org.apache.phoenix.end2end.UserDefinedFunctionsIT.doSetup(UserDefinedFunctionsIT.java:249)

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

Running org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT
org.apache.phoenix.end2end.index.ImmutableIndexWithStatsIT  Time elapsed: 0.003 
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
Running org.apache.phoenix.end2end.index.MutableIndexReplicationIT
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.007 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexFailureIT
org.apache.phoenix.end2end.index.MutableIndexFailureIT  Time elapsed: 0.006 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
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.MutableIndexReplicationIT
org.apache.phoenix.end2end.index.MutableIndexReplicationIT  Time elapsed: 0.003 
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.004 sec <<< 
FAILURE! - in org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT
org.apache.phoenix.end2end.index.ReadOnlyIndexFailureIT  Time elapsed: 0.003 
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: java.io.IOException: Shutting down
at

phoenix git commit: PHOENIX-3018 Write local updates to region than HTable in master branch(Rajeshbabu)

2016-06-29 Thread rajeshbabu 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 7f883ab7e -> 48f4a9e7e


PHOENIX-3018 Write local updates to region than HTable in master 
branch(Rajeshbabu)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: 48f4a9e7e9a1edf72f0ca08a14632b6249e05320
Parents: 7f883ab
Author: Rajeshbabu Chintaguntla 
Authored: Wed Jun 29 12:06:33 2016 +0530
Committer: Rajeshbabu Chintaguntla 
Committed: Wed Jun 29 12:06:33 2016 +0530

--
 .../index/write/ParallelWriterIndexCommitter.java  |  8 ++--
 .../recovery/TrackingParallelWriterIndexCommitter.java |  6 +-
 .../main/java/org/apache/phoenix/util/IndexUtil.java   | 13 +
 3 files changed, 16 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/48f4a9e7/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/ParallelWriterIndexCommitter.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/ParallelWriterIndexCommitter.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/ParallelWriterIndexCommitter.java
index ce9e3ec..9504f30 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/ParallelWriterIndexCommitter.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/ParallelWriterIndexCommitter.java
@@ -39,6 +39,7 @@ import 
org.apache.phoenix.hbase.index.table.CachingHTableFactory;
 import org.apache.phoenix.hbase.index.table.HTableFactory;
 import org.apache.phoenix.hbase.index.table.HTableInterfaceReference;
 import org.apache.phoenix.hbase.index.util.KeyValueBuilder;
+import org.apache.phoenix.util.IndexUtil;
 
 import com.google.common.collect.Multimap;
 
@@ -150,14 +151,9 @@ public class ParallelWriterIndexCommitter implements 
IndexCommitter {
 }
 try {
 if (allowLocalUpdates && env != null) {
-for (Mutation m : mutations) {
-m.setDurability(Durability.SKIP_WAL);
-}
 try {
 throwFailureIfDone();
-env.getRegion().batchMutate(
-mutations.toArray(new 
Mutation[mutations.size()]),
-HConstants.NO_NONCE, HConstants.NO_NONCE);
+IndexUtil.writeLocalUpdates(env.getRegion(), 
mutations, true);
 return null;
 } catch (IOException ignord) {
 // when it's failed we fall back to the 
standard & slow way

http://git-wip-us.apache.org/repos/asf/phoenix/blob/48f4a9e7/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
index 1efbef1..0478d95 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/recovery/TrackingParallelWriterIndexCommitter.java
@@ -156,13 +156,9 @@ public class TrackingParallelWriterIndexCommitter 
implements IndexCommitter {
 }
 if (allowLocalUpdates && env!=null && 
tableReference.getTableName().equals(
 env.getRegion().getTableDesc().getNameAsString())) 
{
-for (Mutation m : mutations) {
-m.setDurability(Durability.SKIP_WAL);
-}
 try {
 throwFailureIfDone();
-
env.getRegion().batchMutate(mutations.toArray(new Mutation[mutations.size()]),
-HConstants.NO_NONCE, HConstants.NO_NONCE);
+IndexUtil.writeLocalUpdates(env.getRegion(), 
mutations, true);
 return Boolean.TRUE;
 } catch (IOException ignord) {
 // when it's failed we fall back to