Build failed in Jenkins: Phoenix | Master #2391

2019-06-06 Thread Apache Jenkins Server 
See 


Changes:

[tdsilva] PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions

--
[...truncated 233.70 KB...]
Fri Jun 07 04:16:08 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:16:28 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:16:48 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
 
Caused by: org.apache.hadoop.hbase.client.RetriesExhaustedException: 
Failed after attempts=16, exceptions:
Fri Jun 07 04:14:40 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:40 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.io.IOException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on local exception: 
org.apache.hadoop.hbase.ipc.FailedServerException: This server is in the failed 
servers list: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:40 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.io.IOException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on local exception: 
org.apache.hadoop.hbase.ipc.FailedServerException: This server is in the failed 
servers list: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:40 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.io.IOException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on local exception: 
org.apache.hadoop.hbase.ipc.FailedServerException: This server is in the failed 
servers list: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:41 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.io.IOException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on local exception: 
org.apache.hadoop.hbase.ipc.FailedServerException: This server is in the failed 
servers list: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:42 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:44 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:48 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:14:58 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:15:08 UTC 2019, RpcRetryingCaller{globalStartTime=1559880880095, 
pause=100, maxAttempts=16}, java.net.ConnectException: Call to 
pietas.apache.org/67.195.81.190:36524 failed on connection exception: 
org.apache.hbase.thirdparty.io.netty.channel.AbstractChannel$AnnotatedConnectException:
 Connection refused: pietas.apache.org/67.195.81.190:36524
Fri Jun 07 04:15:18 UTC 2019,

[phoenix] branch 4.x-HBase-1.5 updated: PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions cause tests to fail

2019-06-06 Thread tdsilva 
This is an automated email from the ASF dual-hosted git repository.

tdsilva pushed a commit to branch 4.x-HBase-1.5
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x-HBase-1.5 by this push:
 new bbf451f  PHOENIX-5316 Use callable instead of runnable so that Pherf 
exceptions cause tests to fail
bbf451f is described below

commit bbf451f99062b752dd65c706d5c508168c382089
Author: Thomas D'Silva 
AuthorDate: Tue Jun 4 16:46:43 2019 -0700

PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions 
cause tests to fail
---
 .../java/org/apache/phoenix/pherf/PherfMainIT.java | 17 +--
 .../main/java/org/apache/phoenix/pherf/Pherf.java  |  7 ++-
 .../pherf/configuration/DataTypeMapping.java   |  4 +-
 .../phoenix/pherf/configuration/Scenario.java  |  2 +
 .../pherf/configuration/XMLConfigParser.java   |  3 +-
 .../apache/phoenix/pherf/jmx/MonitorManager.java   |  9 ++--
 .../apache/phoenix/pherf/rules/RulesApplier.java   | 13 +++--
 .../pherf/workload/MultiThreadedRunner.java| 27 ++-
 .../pherf/workload/MultithreadedDiffer.java|  6 ++-
 .../phoenix/pherf/workload/QueryExecutor.java  | 56 ++
 .../apache/phoenix/pherf/workload/Workload.java|  4 +-
 .../phoenix/pherf/workload/WorkloadExecutor.java   |  5 +-
 .../phoenix/pherf/workload/WriteWorkload.java  | 53 
 .../scenario/prod_test_unsalted_scenario.xml   |  6 +--
 14 files changed, 129 insertions(+), 83 deletions(-)

diff --git 
a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java 
b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
index 2407ef4..6dc900e 100644
--- a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
+++ b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
@@ -22,15 +22,24 @@ import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.ExpectedSystemExit;
 
+import java.util.concurrent.Future;
+
 public class PherfMainIT extends ResultBaseTestIT {
 @Rule
 public final ExpectedSystemExit exit = ExpectedSystemExit.none();
 
 @Test
-public void testPherfMain() {
-String[] args = { "-q",
-"--scenarioFile", ".*prod_test_unsalted_scenario.*",
+public void testPherfMain() throws Exception {
+String[] args = { "-q", "-l",
+"--schemaFile", ".*create_prod_test_unsalted.sql",
+"--scenarioFile", ".*prod_test_unsalted_scenario.xml",
 "-m", "--monitorFrequency", "10" };
-Pherf.main(args);
+Pherf pherf = new Pherf(args);
+pherf.run();
+
+// verify that none of the scenarios threw any exceptions
+for (Future future : pherf.workloadExecutor.jobs.values()) {
+future.get();
+}
 }
 }
\ No newline at end of file
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
index d92ffde..51d6743 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Properties;
 
+import com.google.common.annotations.VisibleForTesting;
+import jline.internal.TestAccessible;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -115,6 +117,9 @@ public class Pherf {
 private final boolean thinDriver;
 private final String queryServerUrl;
 
+@VisibleForTesting
+WorkloadExecutor workloadExecutor;
+
 public Pherf(String[] args) throws Exception {
 CommandLineParser parser = new PosixParser();
 CommandLine command = null;
@@ -201,7 +206,7 @@ public class Pherf {
 public void run() throws Exception {
 MonitorManager monitorManager = null;
 List workloads = new ArrayList<>();
-WorkloadExecutor workloadExecutor = new WorkloadExecutor(properties, 
workloads, !isFunctional);
+workloadExecutor = new WorkloadExecutor(properties, workloads, 
!isFunctional);
 try {
 if (listFiles) {
 ResourceList list = new 
ResourceList(PherfConstants.RESOURCE_DATAMODEL);
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
index 0476df2..129bdc2 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
@@ -29,7 +29,9 @@ public enum DataTypeMapping {
 UNSIGNED_LONG("UNSIGNED_LONG", Types.LONGVARCHAR),
 VARCHAR_ARRAY("VARCHAR ARRAY",

[phoenix] branch master updated: PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions cause tests to fail

2019-06-06 Thread tdsilva 
This is an automated email from the ASF dual-hosted git repository.

tdsilva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/master by this push:
 new 13fd777  PHOENIX-5316 Use callable instead of runnable so that Pherf 
exceptions cause tests to fail
13fd777 is described below

commit 13fd7776d7629c222af63d9a4f38a426fc5ed163
Author: Thomas D'Silva 
AuthorDate: Tue Jun 4 16:46:43 2019 -0700

PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions 
cause tests to fail
---
 .../java/org/apache/phoenix/pherf/PherfMainIT.java | 17 +--
 .../main/java/org/apache/phoenix/pherf/Pherf.java  |  7 ++-
 .../pherf/configuration/DataTypeMapping.java   |  4 +-
 .../phoenix/pherf/configuration/Scenario.java  |  2 +
 .../pherf/configuration/XMLConfigParser.java   |  3 +-
 .../apache/phoenix/pherf/jmx/MonitorManager.java   |  9 ++--
 .../apache/phoenix/pherf/rules/RulesApplier.java   | 13 +++--
 .../pherf/workload/MultiThreadedRunner.java| 27 ++-
 .../pherf/workload/MultithreadedDiffer.java|  6 ++-
 .../phoenix/pherf/workload/QueryExecutor.java  | 56 ++
 .../apache/phoenix/pherf/workload/Workload.java|  4 +-
 .../phoenix/pherf/workload/WorkloadExecutor.java   |  5 +-
 .../phoenix/pherf/workload/WriteWorkload.java  | 53 
 .../scenario/prod_test_unsalted_scenario.xml   |  6 +--
 14 files changed, 129 insertions(+), 83 deletions(-)

diff --git 
a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java 
b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
index 2407ef4..6dc900e 100644
--- a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
+++ b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
@@ -22,15 +22,24 @@ import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.ExpectedSystemExit;
 
+import java.util.concurrent.Future;
+
 public class PherfMainIT extends ResultBaseTestIT {
 @Rule
 public final ExpectedSystemExit exit = ExpectedSystemExit.none();
 
 @Test
-public void testPherfMain() {
-String[] args = { "-q",
-"--scenarioFile", ".*prod_test_unsalted_scenario.*",
+public void testPherfMain() throws Exception {
+String[] args = { "-q", "-l",
+"--schemaFile", ".*create_prod_test_unsalted.sql",
+"--scenarioFile", ".*prod_test_unsalted_scenario.xml",
 "-m", "--monitorFrequency", "10" };
-Pherf.main(args);
+Pherf pherf = new Pherf(args);
+pherf.run();
+
+// verify that none of the scenarios threw any exceptions
+for (Future future : pherf.workloadExecutor.jobs.values()) {
+future.get();
+}
 }
 }
\ No newline at end of file
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
index d92ffde..51d6743 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Properties;
 
+import com.google.common.annotations.VisibleForTesting;
+import jline.internal.TestAccessible;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -115,6 +117,9 @@ public class Pherf {
 private final boolean thinDriver;
 private final String queryServerUrl;
 
+@VisibleForTesting
+WorkloadExecutor workloadExecutor;
+
 public Pherf(String[] args) throws Exception {
 CommandLineParser parser = new PosixParser();
 CommandLine command = null;
@@ -201,7 +206,7 @@ public class Pherf {
 public void run() throws Exception {
 MonitorManager monitorManager = null;
 List workloads = new ArrayList<>();
-WorkloadExecutor workloadExecutor = new WorkloadExecutor(properties, 
workloads, !isFunctional);
+workloadExecutor = new WorkloadExecutor(properties, workloads, 
!isFunctional);
 try {
 if (listFiles) {
 ResourceList list = new 
ResourceList(PherfConstants.RESOURCE_DATAMODEL);
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
index 0476df2..129bdc2 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
@@ -29,7 +29,9 @@ public enum DataTypeMapping {
 UNSIGNED_LONG("UNSIGNED_LONG", Types.LONGVARCHAR),
 VARCHAR_ARRAY("VARCHAR ARRAY", Types.ARRAY),

[phoenix] branch 4.x-HBase-1.4 updated: PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions cause tests to fail

2019-06-06 Thread tdsilva 
This is an automated email from the ASF dual-hosted git repository.

tdsilva pushed a commit to branch 4.x-HBase-1.4
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x-HBase-1.4 by this push:
 new a438558  PHOENIX-5316 Use callable instead of runnable so that Pherf 
exceptions cause tests to fail
a438558 is described below

commit a438558b9806195b62c1364a45898de0d3a42029
Author: Thomas D'Silva 
AuthorDate: Tue Jun 4 16:46:43 2019 -0700

PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions 
cause tests to fail
---
 .../java/org/apache/phoenix/pherf/PherfMainIT.java | 17 +--
 .../main/java/org/apache/phoenix/pherf/Pherf.java  |  7 ++-
 .../pherf/configuration/DataTypeMapping.java   |  4 +-
 .../phoenix/pherf/configuration/Scenario.java  |  2 +
 .../pherf/configuration/XMLConfigParser.java   |  3 +-
 .../apache/phoenix/pherf/jmx/MonitorManager.java   |  9 ++--
 .../apache/phoenix/pherf/rules/RulesApplier.java   | 13 +++--
 .../pherf/workload/MultiThreadedRunner.java| 27 ++-
 .../pherf/workload/MultithreadedDiffer.java|  6 ++-
 .../phoenix/pherf/workload/QueryExecutor.java  | 56 ++
 .../apache/phoenix/pherf/workload/Workload.java|  4 +-
 .../phoenix/pherf/workload/WorkloadExecutor.java   |  5 +-
 .../phoenix/pherf/workload/WriteWorkload.java  | 53 
 .../scenario/prod_test_unsalted_scenario.xml   |  6 +--
 14 files changed, 129 insertions(+), 83 deletions(-)

diff --git 
a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java 
b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
index 2407ef4..6dc900e 100644
--- a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
+++ b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
@@ -22,15 +22,24 @@ import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.ExpectedSystemExit;
 
+import java.util.concurrent.Future;
+
 public class PherfMainIT extends ResultBaseTestIT {
 @Rule
 public final ExpectedSystemExit exit = ExpectedSystemExit.none();
 
 @Test
-public void testPherfMain() {
-String[] args = { "-q",
-"--scenarioFile", ".*prod_test_unsalted_scenario.*",
+public void testPherfMain() throws Exception {
+String[] args = { "-q", "-l",
+"--schemaFile", ".*create_prod_test_unsalted.sql",
+"--scenarioFile", ".*prod_test_unsalted_scenario.xml",
 "-m", "--monitorFrequency", "10" };
-Pherf.main(args);
+Pherf pherf = new Pherf(args);
+pherf.run();
+
+// verify that none of the scenarios threw any exceptions
+for (Future future : pherf.workloadExecutor.jobs.values()) {
+future.get();
+}
 }
 }
\ No newline at end of file
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
index d92ffde..51d6743 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Properties;
 
+import com.google.common.annotations.VisibleForTesting;
+import jline.internal.TestAccessible;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -115,6 +117,9 @@ public class Pherf {
 private final boolean thinDriver;
 private final String queryServerUrl;
 
+@VisibleForTesting
+WorkloadExecutor workloadExecutor;
+
 public Pherf(String[] args) throws Exception {
 CommandLineParser parser = new PosixParser();
 CommandLine command = null;
@@ -201,7 +206,7 @@ public class Pherf {
 public void run() throws Exception {
 MonitorManager monitorManager = null;
 List workloads = new ArrayList<>();
-WorkloadExecutor workloadExecutor = new WorkloadExecutor(properties, 
workloads, !isFunctional);
+workloadExecutor = new WorkloadExecutor(properties, workloads, 
!isFunctional);
 try {
 if (listFiles) {
 ResourceList list = new 
ResourceList(PherfConstants.RESOURCE_DATAMODEL);
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
index 0476df2..129bdc2 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
@@ -29,7 +29,9 @@ public enum DataTypeMapping {
 UNSIGNED_LONG("UNSIGNED_LONG", Types.LONGVARCHAR),
 VARCHAR_ARRAY("VARCHAR ARRAY",

[phoenix] branch 4.x-HBase-1.3 updated: PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions cause tests to fail

2019-06-06 Thread tdsilva 
This is an automated email from the ASF dual-hosted git repository.

tdsilva pushed a commit to branch 4.x-HBase-1.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x-HBase-1.3 by this push:
 new 2c98e22  PHOENIX-5316 Use callable instead of runnable so that Pherf 
exceptions cause tests to fail
2c98e22 is described below

commit 2c98e22ce7b2858d6d6a84593e50fa2291891817
Author: Thomas D'Silva 
AuthorDate: Tue Jun 4 16:46:43 2019 -0700

PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions 
cause tests to fail
---
 .../java/org/apache/phoenix/pherf/PherfMainIT.java | 17 +--
 .../main/java/org/apache/phoenix/pherf/Pherf.java  |  7 ++-
 .../pherf/configuration/DataTypeMapping.java   |  4 +-
 .../phoenix/pherf/configuration/Scenario.java  |  2 +
 .../pherf/configuration/XMLConfigParser.java   |  3 +-
 .../apache/phoenix/pherf/jmx/MonitorManager.java   |  9 ++--
 .../apache/phoenix/pherf/rules/RulesApplier.java   | 13 +++--
 .../pherf/workload/MultiThreadedRunner.java| 27 ++-
 .../pherf/workload/MultithreadedDiffer.java|  6 ++-
 .../phoenix/pherf/workload/QueryExecutor.java  | 56 ++
 .../apache/phoenix/pherf/workload/Workload.java|  4 +-
 .../phoenix/pherf/workload/WorkloadExecutor.java   |  5 +-
 .../phoenix/pherf/workload/WriteWorkload.java  | 53 
 .../scenario/prod_test_unsalted_scenario.xml   |  6 +--
 14 files changed, 129 insertions(+), 83 deletions(-)

diff --git 
a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java 
b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
index 2407ef4..6dc900e 100644
--- a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
+++ b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
@@ -22,15 +22,24 @@ import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.ExpectedSystemExit;
 
+import java.util.concurrent.Future;
+
 public class PherfMainIT extends ResultBaseTestIT {
 @Rule
 public final ExpectedSystemExit exit = ExpectedSystemExit.none();
 
 @Test
-public void testPherfMain() {
-String[] args = { "-q",
-"--scenarioFile", ".*prod_test_unsalted_scenario.*",
+public void testPherfMain() throws Exception {
+String[] args = { "-q", "-l",
+"--schemaFile", ".*create_prod_test_unsalted.sql",
+"--scenarioFile", ".*prod_test_unsalted_scenario.xml",
 "-m", "--monitorFrequency", "10" };
-Pherf.main(args);
+Pherf pherf = new Pherf(args);
+pherf.run();
+
+// verify that none of the scenarios threw any exceptions
+for (Future future : pherf.workloadExecutor.jobs.values()) {
+future.get();
+}
 }
 }
\ No newline at end of file
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
index d92ffde..51d6743 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Properties;
 
+import com.google.common.annotations.VisibleForTesting;
+import jline.internal.TestAccessible;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -115,6 +117,9 @@ public class Pherf {
 private final boolean thinDriver;
 private final String queryServerUrl;
 
+@VisibleForTesting
+WorkloadExecutor workloadExecutor;
+
 public Pherf(String[] args) throws Exception {
 CommandLineParser parser = new PosixParser();
 CommandLine command = null;
@@ -201,7 +206,7 @@ public class Pherf {
 public void run() throws Exception {
 MonitorManager monitorManager = null;
 List workloads = new ArrayList<>();
-WorkloadExecutor workloadExecutor = new WorkloadExecutor(properties, 
workloads, !isFunctional);
+workloadExecutor = new WorkloadExecutor(properties, workloads, 
!isFunctional);
 try {
 if (listFiles) {
 ResourceList list = new 
ResourceList(PherfConstants.RESOURCE_DATAMODEL);
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
index 0476df2..129bdc2 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
@@ -29,7 +29,9 @@ public enum DataTypeMapping {
 UNSIGNED_LONG("UNSIGNED_LONG", Types.LONGVARCHAR),
 VARCHAR_ARRAY("VARCHAR ARRAY",

[phoenix] branch 4.14-HBase-1.4 updated: PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions cause tests to fail

2019-06-06 Thread tdsilva 
This is an automated email from the ASF dual-hosted git repository.

tdsilva pushed a commit to branch 4.14-HBase-1.4
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.14-HBase-1.4 by this push:
 new b22e9a2  PHOENIX-5316 Use callable instead of runnable so that Pherf 
exceptions cause tests to fail
b22e9a2 is described below

commit b22e9a2d7464453383f416097841c541b727478c
Author: Thomas D'Silva 
AuthorDate: Tue Jun 4 16:46:43 2019 -0700

PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions 
cause tests to fail
---
 .../java/org/apache/phoenix/pherf/PherfMainIT.java | 17 +--
 .../main/java/org/apache/phoenix/pherf/Pherf.java  |  7 ++-
 .../pherf/configuration/DataTypeMapping.java   |  4 +-
 .../phoenix/pherf/configuration/Scenario.java  |  2 +
 .../pherf/configuration/XMLConfigParser.java   |  3 +-
 .../apache/phoenix/pherf/jmx/MonitorManager.java   |  9 ++--
 .../apache/phoenix/pherf/rules/RulesApplier.java   | 13 +++--
 .../pherf/workload/MultiThreadedRunner.java| 27 ++-
 .../pherf/workload/MultithreadedDiffer.java|  6 ++-
 .../phoenix/pherf/workload/QueryExecutor.java  | 56 ++
 .../apache/phoenix/pherf/workload/Workload.java|  4 +-
 .../phoenix/pherf/workload/WorkloadExecutor.java   |  5 +-
 .../phoenix/pherf/workload/WriteWorkload.java  | 53 
 .../scenario/prod_test_unsalted_scenario.xml   |  6 +--
 14 files changed, 129 insertions(+), 83 deletions(-)

diff --git 
a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java 
b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
index 2407ef4..6dc900e 100644
--- a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
+++ b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
@@ -22,15 +22,24 @@ import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.ExpectedSystemExit;
 
+import java.util.concurrent.Future;
+
 public class PherfMainIT extends ResultBaseTestIT {
 @Rule
 public final ExpectedSystemExit exit = ExpectedSystemExit.none();
 
 @Test
-public void testPherfMain() {
-String[] args = { "-q",
-"--scenarioFile", ".*prod_test_unsalted_scenario.*",
+public void testPherfMain() throws Exception {
+String[] args = { "-q", "-l",
+"--schemaFile", ".*create_prod_test_unsalted.sql",
+"--scenarioFile", ".*prod_test_unsalted_scenario.xml",
 "-m", "--monitorFrequency", "10" };
-Pherf.main(args);
+Pherf pherf = new Pherf(args);
+pherf.run();
+
+// verify that none of the scenarios threw any exceptions
+for (Future future : pherf.workloadExecutor.jobs.values()) {
+future.get();
+}
 }
 }
\ No newline at end of file
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
index d92ffde..51d6743 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Properties;
 
+import com.google.common.annotations.VisibleForTesting;
+import jline.internal.TestAccessible;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -115,6 +117,9 @@ public class Pherf {
 private final boolean thinDriver;
 private final String queryServerUrl;
 
+@VisibleForTesting
+WorkloadExecutor workloadExecutor;
+
 public Pherf(String[] args) throws Exception {
 CommandLineParser parser = new PosixParser();
 CommandLine command = null;
@@ -201,7 +206,7 @@ public class Pherf {
 public void run() throws Exception {
 MonitorManager monitorManager = null;
 List workloads = new ArrayList<>();
-WorkloadExecutor workloadExecutor = new WorkloadExecutor(properties, 
workloads, !isFunctional);
+workloadExecutor = new WorkloadExecutor(properties, workloads, 
!isFunctional);
 try {
 if (listFiles) {
 ResourceList list = new 
ResourceList(PherfConstants.RESOURCE_DATAMODEL);
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
index 0476df2..129bdc2 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
@@ -29,7 +29,9 @@ public enum DataTypeMapping {
 UNSIGNED_LONG("UNSIGNED_LONG", Types.LONGVARCHAR),
 VARCHAR_ARRAY("VARCHAR ARRAY",

[phoenix] branch 4.14-HBase-1.3 updated: PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions cause tests to fail

2019-06-06 Thread tdsilva 
This is an automated email from the ASF dual-hosted git repository.

tdsilva pushed a commit to branch 4.14-HBase-1.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.14-HBase-1.3 by this push:
 new 8512ece  PHOENIX-5316 Use callable instead of runnable so that Pherf 
exceptions cause tests to fail
8512ece is described below

commit 8512ecefd4370dfc4e3fc547de858ac8abe11984
Author: Thomas D'Silva 
AuthorDate: Tue Jun 4 16:46:43 2019 -0700

PHOENIX-5316 Use callable instead of runnable so that Pherf exceptions 
cause tests to fail
---
 .../java/org/apache/phoenix/pherf/PherfMainIT.java | 17 +--
 .../main/java/org/apache/phoenix/pherf/Pherf.java  |  7 ++-
 .../pherf/configuration/DataTypeMapping.java   |  4 +-
 .../phoenix/pherf/configuration/Scenario.java  |  2 +
 .../pherf/configuration/XMLConfigParser.java   |  3 +-
 .../apache/phoenix/pherf/jmx/MonitorManager.java   |  9 ++--
 .../apache/phoenix/pherf/rules/RulesApplier.java   | 13 +++--
 .../pherf/workload/MultiThreadedRunner.java| 27 ++-
 .../pherf/workload/MultithreadedDiffer.java|  6 ++-
 .../phoenix/pherf/workload/QueryExecutor.java  | 56 ++
 .../apache/phoenix/pherf/workload/Workload.java|  4 +-
 .../phoenix/pherf/workload/WorkloadExecutor.java   |  5 +-
 .../phoenix/pherf/workload/WriteWorkload.java  | 53 
 .../scenario/prod_test_unsalted_scenario.xml   |  6 +--
 14 files changed, 129 insertions(+), 83 deletions(-)

diff --git 
a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java 
b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
index 2407ef4..6dc900e 100644
--- a/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
+++ b/phoenix-pherf/src/it/java/org/apache/phoenix/pherf/PherfMainIT.java
@@ -22,15 +22,24 @@ import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.ExpectedSystemExit;
 
+import java.util.concurrent.Future;
+
 public class PherfMainIT extends ResultBaseTestIT {
 @Rule
 public final ExpectedSystemExit exit = ExpectedSystemExit.none();
 
 @Test
-public void testPherfMain() {
-String[] args = { "-q",
-"--scenarioFile", ".*prod_test_unsalted_scenario.*",
+public void testPherfMain() throws Exception {
+String[] args = { "-q", "-l",
+"--schemaFile", ".*create_prod_test_unsalted.sql",
+"--scenarioFile", ".*prod_test_unsalted_scenario.xml",
 "-m", "--monitorFrequency", "10" };
-Pherf.main(args);
+Pherf pherf = new Pherf(args);
+pherf.run();
+
+// verify that none of the scenarios threw any exceptions
+for (Future future : pherf.workloadExecutor.jobs.values()) {
+future.get();
+}
 }
 }
\ No newline at end of file
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
index d92ffde..51d6743 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/Pherf.java
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Properties;
 
+import com.google.common.annotations.VisibleForTesting;
+import jline.internal.TestAccessible;
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.CommandLineParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -115,6 +117,9 @@ public class Pherf {
 private final boolean thinDriver;
 private final String queryServerUrl;
 
+@VisibleForTesting
+WorkloadExecutor workloadExecutor;
+
 public Pherf(String[] args) throws Exception {
 CommandLineParser parser = new PosixParser();
 CommandLine command = null;
@@ -201,7 +206,7 @@ public class Pherf {
 public void run() throws Exception {
 MonitorManager monitorManager = null;
 List workloads = new ArrayList<>();
-WorkloadExecutor workloadExecutor = new WorkloadExecutor(properties, 
workloads, !isFunctional);
+workloadExecutor = new WorkloadExecutor(properties, workloads, 
!isFunctional);
 try {
 if (listFiles) {
 ResourceList list = new 
ResourceList(PherfConstants.RESOURCE_DATAMODEL);
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
index 0476df2..129bdc2 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/configuration/DataTypeMapping.java
@@ -29,7 +29,9 @@ public enum DataTypeMapping {
 UNSIGNED_LONG("UNSIGNED_LONG", Types.LONGVARCHAR),
 VARCHAR_ARRAY("VARCHAR ARRAY",

Build failed in Jenkins: Phoenix | Master #2390

2019-06-06 Thread Apache Jenkins Server 
See 


Changes:

[chinmayskulkarni] PHOENIX-5311 Fix distributed cluster test resource (hbase 
table) leak

--
[...truncated 112.11 KB...]
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 285.786 
s - in org.apache.phoenix.end2end.join.SubqueryUsingSortMergeJoinIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 76.456 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Running org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.008 
s - in org.apache.phoenix.trace.PhoenixTracingEndToEndIT
[INFO] Running org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.202 s 
- in org.apache.phoenix.replication.SystemCatalogWALEntryFilterIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 948.652 
s - in org.apache.phoenix.end2end.join.HashJoinLocalIndexIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 65.094 s 
- in org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 35.467 s 
- in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 406.146 
s - in org.apache.phoenix.end2end.join.SubqueryIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.616 s 
- in org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.228 s 
- in org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 904.837 
s - in org.apache.phoenix.end2end.join.SortMergeJoinLocalIndexIT
[INFO] Tests run: 28, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 233.146 
s - in org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 446.167 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 78, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 758.95 
s - in org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] 
[INFO] Results:
[INFO] 
[ERROR] Failures: 
[ERROR]   
UpgradeIT.testMapTableToNamespaceDuringUpgrade:189->BaseTest.verifySequenceValue:1782->BaseTest.verifySequence:1804
 expected:<-9223372036854775805> but was:<-9223372036854774707>
[INFO] 
[ERROR] Tests run: 3737, Failures: 1, Errors: 0, Skipped: 11
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (HBaseManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test 
(NeedTheirOwnClusterTests) @ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[WARNING] Tests run: 1, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 0.001 
s - in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.324 s 
- in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.116 s 
- in org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.022 s 
- in org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 55.718 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Running org.apache.phoenix.end2end.CostBasedDecisionIT
[INFO] Running org.apache.phoenix.end2end.DropSchemaIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 21.336 s 
- in org.apache.phoenix.end2end.DropSchemaIT
[INFO]

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

2019-06-06 Thread Apache Jenkins Server 
See 


Changes:

[chinmayskulkarni] PHOENIX-5311 Fix distributed cluster test resource (hbase 
table) leak

--
[...truncated 595.65 KB...]
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 43.344 s 
- in org.apache.phoenix.rpc.UpdateCacheIT
[INFO] Running org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] Running org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 23.467 s 
- in org.apache.phoenix.tx.FlappingTransactionIT
[INFO] Running org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 15, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 167.902 
s - in org.apache.phoenix.end2end.join.SubqueryUsingSortMergeJoinIT
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 12.33 s 
- in org.apache.phoenix.trace.PhoenixTableMetricsWriterIT
[INFO] Running org.apache.phoenix.util.IndexScrutinyIT
[INFO] Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 237.353 
s - in org.apache.phoenix.end2end.join.SubqueryIT
[INFO] Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 49.022 s 
- in org.apache.phoenix.iterate.RoundRobinResultIteratorIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 18.17 s 
- in org.apache.phoenix.util.IndexScrutinyIT
[INFO] Running org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 28, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 161.341 
s - in org.apache.phoenix.tx.TransactionIT
[INFO] Tests run: 34, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 587.19 
s - in org.apache.phoenix.end2end.join.SortMergeJoinLocalIndexIT
[INFO] Tests run: 50, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 337.303 
s - in org.apache.phoenix.tx.TxCheckpointIT
[INFO] Tests run: 78, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 628.353 
s - in org.apache.phoenix.tx.ParameterizedTransactionIT
[INFO] 
[INFO] Results:
[INFO] 
[ERROR] Failures: 
[ERROR]   SortMergeJoinNoSpoolingIT.testJoinWithMemoryLimit:74 Expected 
PhoenixIOException due to IllegalStateException
[ERROR] Errors: 
[ERROR]   
RowValueConstructorIT.testQueryMoreWithLeadingPKColSkippedInRowValueConstructor:544->_testQueryMoreWithLeadingPKColSkippedInRowValueConstructor:584
 » PhoenixIO
[ERROR]   
RowValueConstructorIT.testQueryMoreWithLeadingPKColSkippedInRowValueConstructor_salted:549->_testQueryMoreWithLeadingPKColSkippedInRowValueConstructor:584
 » PhoenixIO
[ERROR]   
RowValueConstructorIT.testQueryMoreWithSubsetofPKColsInRowValueConstructor:472->_testQueryMoreWithSubsetofPKColsInRowValueConstructor:515
 » PhoenixIO
[ERROR]   
RowValueConstructorIT.testQueryMoreWithSubsetofPKColsInRowValueConstructor_salted:477->_testQueryMoreWithSubsetofPKColsInRowValueConstructor:515
 » PhoenixIO
[INFO] 
[ERROR] Tests run: 3732, Failures: 1, Errors: 4, Skipped: 2
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test (HBaseManagedTimeTests) 
@ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] 
[INFO] --- maven-failsafe-plugin:2.20:integration-test 
(NeedTheirOwnClusterTests) @ phoenix-core ---
[INFO] 
[INFO] ---
[INFO]  T E S T S
[INFO] ---
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 29.67 s 
- in 
org.apache.hadoop.hbase.regionserver.wal.WALReplayWithIndexWritesAndCompressedWALIT
[INFO] Running 
org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.91 s - 
in org.apache.hadoop.hbase.regionserver.wal.WALRecoveryRegionPostOpenIT
[INFO] Running org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Running org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Running org.apache.phoenix.end2end.CsvBulkLoadToolIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.437 s 
- in org.apache.phoenix.end2end.CountDistinctCompressionIT
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 28.073 s 
- in org.apache.phoenix.end2end.ConnectionUtilIT
[INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.492 s 
- in org.apache.phoenix.end2end.ContextClassloaderIT
[INFO] Running org.apache.phoenix.end2end.CostBasedDecisionIT
[INFO] Running org.apache.phoenix.end2end.DropSchemaIT
[INFO] Running org.apache.phoenix.end2end.IndexExtendedIT
[INFO] Running org.apache.phoenix.end2end.IndexBuildTimestampIT
[INFO]

[phoenix] branch 4.x-HBase-1.5 updated: PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

2019-06-06 Thread chinmayskulkarni 
This is an automated email from the ASF dual-hosted git repository.

chinmayskulkarni pushed a commit to branch 4.x-HBase-1.5
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x-HBase-1.5 by this push:
 new ce7221a  PHOENIX-5311 Fix distributed cluster test resource (hbase 
table) leak
ce7221a is described below

commit ce7221aed1cbf90c4ebfe4e970f35f6a26e4f365
Author: István Tóth 
AuthorDate: Thu May 30 14:37:29 2019 +0200

PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

Change-Id: Ie325febbdf613198e2c2037760d5d6cdc79e997e
---
 .../phoenix/end2end/ParallelStatsDisabledIT.java   |  4 ++--
 .../phoenix/end2end/ParallelStatsEnabledIT.java|  4 ++--
 .../java/org/apache/phoenix/query/BaseTest.java| 25 --
 3 files changed, 23 insertions(+), 10 deletions(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
index 8ea8dc8..a46de49 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
@@ -62,8 +62,8 @@ public abstract class ParallelStatsDisabledIT extends 
BaseTest {
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 
 protected ResultSet executeQuery(Connection conn, QueryBuilder 
queryBuilder) throws SQLException {
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
index 7028db3..a383ea1 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
@@ -48,7 +48,7 @@ public abstract class ParallelStatsEnabledIT extends BaseTest 
{
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 }
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
index 305249b..26d2655 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
@@ -19,6 +19,7 @@ package org.apache.phoenix.query;
 
 import static 
org.apache.phoenix.hbase.index.write.ParallelWriterIndexCommitter.NUM_CONCURRENT_INDEX_WRITER_THREADS_CONF_KEY;
 import static org.apache.phoenix.query.QueryConstants.MILLIS_IN_DAY;
+import static org.apache.phoenix.query.QueryServices.DROP_METADATA_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.CURRENT_SCN_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL_TERMINATOR;
@@ -444,7 +445,7 @@ public abstract class BaseTest {
 boolean isDistributedCluster = isDistributedClusterModeEnabled(conf);
 if (!isDistributedCluster) {
 return initMiniCluster(conf, overrideProps);
-   } else {
+} else {
 return initClusterDistributedMode(conf, overrideProps);
 }
 }
@@ -629,6 +630,11 @@ public abstract class BaseTest {
 private static PhoenixTestDriver newTestDriver(ReadOnlyProps props) throws 
Exception {
 PhoenixTestDriver newDriver;
 String driverClassName = props.get(DRIVER_CLASS_NAME_ATTRIB);
+if(isDistributedClusterModeEnabled(config)) {
+HashMap distPropMap = new HashMap<>(1);
+distPropMap.put(DROP_METADATA_ATTRIB, Boolean.TRUE.toString());
+props = new ReadOnlyProps(props, 
distPropMap.entrySet().iterator());
+}
 if (driverClassName == null) {
 newDriver = new PhoenixTestDriver(props);
 } else {
@@ -767,14 +773,21 @@ public abstract class BaseTest {
 return "S" + Integer.toString(MAX_SEQ_SUFFIX_VALUE + 
nextName).substring(1);
 }
 
-public static void tearDownMiniClusterIfBeyondThreshold() throws Exception 
{
+public static void freeResourcesIfBeyondThreshold() throws Exception {
 if (TABLE_COUNTER.get() > TEARDOWN_THRESHOLD) {
 int numTables = TABLE_COUNTER.get();
 TABLE_COUNTER.set(0);
-logger.info(
-"Shutting down mini cluster because number of tables on this 
mini cluster is likely greater than "
-+ TEARDOWN_THRESHOLD);
-

[phoenix] branch 4.x-HBase-1.4 updated: PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

2019-06-06 Thread chinmayskulkarni 
This is an automated email from the ASF dual-hosted git repository.

chinmayskulkarni pushed a commit to branch 4.x-HBase-1.4
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x-HBase-1.4 by this push:
 new 0e05027  PHOENIX-5311 Fix distributed cluster test resource (hbase 
table) leak
0e05027 is described below

commit 0e05027aefa3ac7b8410f4e935a7bce7254bf25d
Author: István Tóth 
AuthorDate: Thu May 30 14:37:29 2019 +0200

PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

Change-Id: Ie325febbdf613198e2c2037760d5d6cdc79e997e
---
 .../phoenix/end2end/ParallelStatsDisabledIT.java   |  4 ++--
 .../phoenix/end2end/ParallelStatsEnabledIT.java|  4 ++--
 .../java/org/apache/phoenix/query/BaseTest.java| 25 --
 3 files changed, 23 insertions(+), 10 deletions(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
index 8ea8dc8..a46de49 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
@@ -62,8 +62,8 @@ public abstract class ParallelStatsDisabledIT extends 
BaseTest {
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 
 protected ResultSet executeQuery(Connection conn, QueryBuilder 
queryBuilder) throws SQLException {
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
index 7028db3..a383ea1 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
@@ -48,7 +48,7 @@ public abstract class ParallelStatsEnabledIT extends BaseTest 
{
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 }
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
index 305249b..26d2655 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
@@ -19,6 +19,7 @@ package org.apache.phoenix.query;
 
 import static 
org.apache.phoenix.hbase.index.write.ParallelWriterIndexCommitter.NUM_CONCURRENT_INDEX_WRITER_THREADS_CONF_KEY;
 import static org.apache.phoenix.query.QueryConstants.MILLIS_IN_DAY;
+import static org.apache.phoenix.query.QueryServices.DROP_METADATA_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.CURRENT_SCN_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL_TERMINATOR;
@@ -444,7 +445,7 @@ public abstract class BaseTest {
 boolean isDistributedCluster = isDistributedClusterModeEnabled(conf);
 if (!isDistributedCluster) {
 return initMiniCluster(conf, overrideProps);
-   } else {
+} else {
 return initClusterDistributedMode(conf, overrideProps);
 }
 }
@@ -629,6 +630,11 @@ public abstract class BaseTest {
 private static PhoenixTestDriver newTestDriver(ReadOnlyProps props) throws 
Exception {
 PhoenixTestDriver newDriver;
 String driverClassName = props.get(DRIVER_CLASS_NAME_ATTRIB);
+if(isDistributedClusterModeEnabled(config)) {
+HashMap distPropMap = new HashMap<>(1);
+distPropMap.put(DROP_METADATA_ATTRIB, Boolean.TRUE.toString());
+props = new ReadOnlyProps(props, 
distPropMap.entrySet().iterator());
+}
 if (driverClassName == null) {
 newDriver = new PhoenixTestDriver(props);
 } else {
@@ -767,14 +773,21 @@ public abstract class BaseTest {
 return "S" + Integer.toString(MAX_SEQ_SUFFIX_VALUE + 
nextName).substring(1);
 }
 
-public static void tearDownMiniClusterIfBeyondThreshold() throws Exception 
{
+public static void freeResourcesIfBeyondThreshold() throws Exception {
 if (TABLE_COUNTER.get() > TEARDOWN_THRESHOLD) {
 int numTables = TABLE_COUNTER.get();
 TABLE_COUNTER.set(0);
-logger.info(
-"Shutting down mini cluster because number of tables on this 
mini cluster is likely greater than "
-+ TEARDOWN_THRESHOLD);
-

[phoenix] branch 4.x-HBase-1.3 updated: PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

2019-06-06 Thread chinmayskulkarni 
This is an automated email from the ASF dual-hosted git repository.

chinmayskulkarni pushed a commit to branch 4.x-HBase-1.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x-HBase-1.3 by this push:
 new 5c49fd5  PHOENIX-5311 Fix distributed cluster test resource (hbase 
table) leak
5c49fd5 is described below

commit 5c49fd54725a77b8f3540e610b49ba46d874916d
Author: István Tóth 
AuthorDate: Thu May 30 14:37:29 2019 +0200

PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

Change-Id: Ie325febbdf613198e2c2037760d5d6cdc79e997e
---
 .../phoenix/end2end/ParallelStatsDisabledIT.java   |  4 ++--
 .../phoenix/end2end/ParallelStatsEnabledIT.java|  4 ++--
 .../java/org/apache/phoenix/query/BaseTest.java| 25 --
 3 files changed, 23 insertions(+), 10 deletions(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
index 2fcc3ea..ca2cff9 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
@@ -52,8 +52,8 @@ public abstract class ParallelStatsDisabledIT extends 
BaseTest {
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 
 protected ResultSet executeQuery(Connection conn, QueryBuilder 
queryBuilder) throws SQLException {
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
index 7028db3..a383ea1 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
@@ -48,7 +48,7 @@ public abstract class ParallelStatsEnabledIT extends BaseTest 
{
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 }
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
index 329cde2..1197659 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
@@ -19,6 +19,7 @@ package org.apache.phoenix.query;
 
 import static 
org.apache.phoenix.hbase.index.write.ParallelWriterIndexCommitter.NUM_CONCURRENT_INDEX_WRITER_THREADS_CONF_KEY;
 import static org.apache.phoenix.query.QueryConstants.MILLIS_IN_DAY;
+import static org.apache.phoenix.query.QueryServices.DROP_METADATA_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.CURRENT_SCN_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL_TERMINATOR;
@@ -444,7 +445,7 @@ public abstract class BaseTest {
 boolean isDistributedCluster = isDistributedClusterModeEnabled(conf);
 if (!isDistributedCluster) {
 return initMiniCluster(conf, overrideProps);
-   } else {
+} else {
 return initClusterDistributedMode(conf, overrideProps);
 }
 }
@@ -629,6 +630,11 @@ public abstract class BaseTest {
 private static PhoenixTestDriver newTestDriver(ReadOnlyProps props) throws 
Exception {
 PhoenixTestDriver newDriver;
 String driverClassName = props.get(DRIVER_CLASS_NAME_ATTRIB);
+if(isDistributedClusterModeEnabled(config)) {
+HashMap distPropMap = new HashMap<>(1);
+distPropMap.put(DROP_METADATA_ATTRIB, Boolean.TRUE.toString());
+props = new ReadOnlyProps(props, 
distPropMap.entrySet().iterator());
+}
 if (driverClassName == null) {
 newDriver = new PhoenixTestDriver(props);
 } else {
@@ -767,14 +773,21 @@ public abstract class BaseTest {
 return "S" + Integer.toString(MAX_SEQ_SUFFIX_VALUE + 
nextName).substring(1);
 }
 
-public static void tearDownMiniClusterIfBeyondThreshold() throws Exception 
{
+public static void freeResourcesIfBeyondThreshold() throws Exception {
 if (TABLE_COUNTER.get() > TEARDOWN_THRESHOLD) {
 int numTables = TABLE_COUNTER.get();
 TABLE_COUNTER.set(0);
-logger.info(
-"Shutting down mini cluster because number of tables on this 
mini cluster is likely greater than "
-+ TEARDOWN_THRESHOLD);
-

[phoenix] branch master updated: PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

2019-06-06 Thread chinmayskulkarni 
This is an automated email from the ASF dual-hosted git repository.

chinmayskulkarni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/master by this push:
 new 5303d29  PHOENIX-5311 Fix distributed cluster test resource (hbase 
table) leak
5303d29 is described below

commit 5303d292a4c875f8ee8f484094c897f8e7595e63
Author: István Tóth 
AuthorDate: Thu May 30 14:37:29 2019 +0200

PHOENIX-5311 Fix distributed cluster test resource (hbase table) leak

Change-Id: Ie325febbdf613198e2c2037760d5d6cdc79e997e
---
 .../phoenix/end2end/ParallelStatsDisabledIT.java   |  4 ++--
 .../phoenix/end2end/ParallelStatsEnabledIT.java|  4 ++--
 .../java/org/apache/phoenix/query/BaseTest.java| 25 --
 3 files changed, 23 insertions(+), 10 deletions(-)

diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
index 8ea8dc8..a46de49 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsDisabledIT.java
@@ -62,8 +62,8 @@ public abstract class ParallelStatsDisabledIT extends 
BaseTest {
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 
 protected ResultSet executeQuery(Connection conn, QueryBuilder 
queryBuilder) throws SQLException {
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
index 7028db3..a383ea1 100644
--- 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
+++ 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ParallelStatsEnabledIT.java
@@ -48,7 +48,7 @@ public abstract class ParallelStatsEnabledIT extends BaseTest 
{
 }
 
 @AfterClass
-public static void tearDownMiniCluster() throws Exception {
-BaseTest.tearDownMiniClusterIfBeyondThreshold();
+public static void freeResources() throws Exception {
+BaseTest.freeResourcesIfBeyondThreshold();
 }
 }
diff --git a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java 
b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
index e4a8e86..96992ee 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/query/BaseTest.java
@@ -19,6 +19,7 @@ package org.apache.phoenix.query;
 
 import static 
org.apache.phoenix.hbase.index.write.ParallelWriterIndexCommitter.NUM_CONCURRENT_INDEX_WRITER_THREADS_CONF_KEY;
 import static org.apache.phoenix.query.QueryConstants.MILLIS_IN_DAY;
+import static org.apache.phoenix.query.QueryServices.DROP_METADATA_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.CURRENT_SCN_ATTRIB;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL;
 import static org.apache.phoenix.util.PhoenixRuntime.JDBC_PROTOCOL_TERMINATOR;
@@ -444,7 +445,7 @@ public abstract class BaseTest {
 boolean isDistributedCluster = isDistributedClusterModeEnabled(conf);
 if (!isDistributedCluster) {
 return initMiniCluster(conf, overrideProps);
-   } else {
+} else {
 return initClusterDistributedMode(conf, overrideProps);
 }
 }
@@ -629,6 +630,11 @@ public abstract class BaseTest {
 private static PhoenixTestDriver newTestDriver(ReadOnlyProps props) throws 
Exception {
 PhoenixTestDriver newDriver;
 String driverClassName = props.get(DRIVER_CLASS_NAME_ATTRIB);
+if(isDistributedClusterModeEnabled(config)) {
+HashMap distPropMap = new HashMap<>(1);
+distPropMap.put(DROP_METADATA_ATTRIB, Boolean.TRUE.toString());
+props = new ReadOnlyProps(props, 
distPropMap.entrySet().iterator());
+}
 if (driverClassName == null) {
 newDriver = new PhoenixTestDriver(props);
 } else {
@@ -767,14 +773,21 @@ public abstract class BaseTest {
 return "S" + Integer.toString(MAX_SEQ_SUFFIX_VALUE + 
nextName).substring(1);
 }
 
-public static void tearDownMiniClusterIfBeyondThreshold() throws Exception 
{
+public static void freeResourcesIfBeyondThreshold() throws Exception {
 if (TABLE_COUNTER.get() > TEARDOWN_THRESHOLD) {
 int numTables = TABLE_COUNTER.get();
 TABLE_COUNTER.set(0);
-logger.info(
-"Shutting down mini cluster because number of tables on this 
mini cluster is likely greater than "
-+ TEARDOWN_THRESHOLD);
-

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

2019-06-06 Thread Apache Jenkins Server 
See 


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

[Phoenix_Compile_Compat_wHBase] $ /bin/bash /tmp/jenkins6325343533769606933.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) 386431
max locked memory   (kbytes, -l) 64
max memory size (kbytes, -m) unlimited
open files  (-n) 6
pipe size(512 bytes, -p) 8
POSIX message queues (bytes, -q) 819200
real-time priority  (-r) 0
stack size  (kbytes, -s) 8192
cpu time   (seconds, -t) unlimited
max user processes  (-u) 10240
virtual memory  (kbytes, -v) unlimited
file locks  (-x) unlimited
core id : 0
core id : 1
core id : 2
core id : 3
core id : 4
core id : 5
physical id : 0
physical id : 1
MemTotal:   98963744 kB
MemFree: 8422660 kB
Filesystem  Size  Used Avail Use% Mounted on
udev 48G 0   48G   0% /dev
tmpfs   9.5G  978M  8.5G  11% /run
/dev/sda3   3.6T  453G  3.0T  13% /
tmpfs48G  504K   48G   1% /dev/shm
tmpfs   5.0M 0  5.0M   0% /run/lock
tmpfs48G 0   48G   0% /sys/fs/cgroup
/dev/sda2   473M  236M  213M  53% /boot
tmpfs   9.5G  4.0K  9.5G   1% /run/user/910
tmpfs   9.5G 0  9.5G   0% /run/user/1000
/dev/loop9   90M   90M 0 100% /snap/core/6673
/dev/loop7   54M   54M 0 100% /snap/lxd/10526
/dev/loop12  54M   54M 0 100% /snap/lxd/10601
/dev/loop1   57M   57M 0 100% /snap/snapcraft/2832
/dev/loop8   90M   90M 0 100% /snap/core/6818
/dev/loop10  57M   57M 0 100% /snap/snapcraft/2900
/dev/loop13  55M   55M 0 100% /snap/lxd/10756
/dev/loop3   89M   89M 0 100% /snap/core/6964
/dev/loop5   57M   57M 0 100% /snap/snapcraft/2947
apache-maven-2.2.1
apache-maven-3.0.4
apache-maven-3.0.5
apache-maven-3.1.1
apache-maven-3.2.1
apache-maven-3.2.5
apache-maven-3.3.3
apache-maven-3.3.9
apache-maven-3.5.0
apache-maven-3.5.2
apache-maven-3.5.4
apache-maven-3.6.0
latest
latest2
latest3


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

Cloning into 'hbase'...
Switched to a new branch '0.98'
Branch 0.98 set up to track remote branch 0.98 from origin.
[ERROR] Plugin org.codehaus.mojo:findbugs-maven-plugin:2.5.2 or one of its 
dependencies could not be resolved: Failed to read artifact descriptor for 
org.codehaus.mojo:findbugs-maven-plugin:jar:2.5.2: Could not transfer artifact 
org.codehaus.mojo:findbugs-maven-plugin:pom:2.5.2 from/to central 
(https://repo.maven.apache.org/maven2): Received fatal alert: protocol_version 
-> [Help 1]
[ERROR] 
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e 
switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR] 
[ERROR] For more information about the errors and possible solutions, please 
read the following articles:
[ERROR] [Help 1] 
http://cwiki.apache.org/confluence/display/MAVEN/PluginResolutionException
Build step 'Execute shell' marked build as failure