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

2015-10-22 Thread Apache Jenkins Server 
See 

Changes:

[cmarcel] PHOENIX-2345 - Pherf - ResultManager does not flush

--
[...truncated 6889 lines...]
[INFO] Failsafe report directory: 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/target/failsafe-reports
[INFO] 
[INFO] --- maven-failsafe-plugin:2.18:verify (HBaseManagedTimeTests) @ 
phoenix-core ---
[INFO] Failsafe report directory: 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/target/failsafe-reports
[INFO] 
[INFO] --- maven-failsafe-plugin:2.18:verify (NeedTheirOwnClusterTests) @ 
phoenix-core ---
[INFO] Failsafe report directory: 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/target/failsafe-reports
[INFO] 
[INFO] --- maven-install-plugin:2.5.1:install (default-install) @ phoenix-core 
---
[INFO] Installing 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/target/archive-tmp/phoenix-core-4.6.0-HBase-1.0.jar
 to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix-core/4.6.0-HBase-1.0/phoenix-core-4.6.0-HBase-1.0.jar
[INFO] Installing 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/pom.xml 
to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix-core/4.6.0-HBase-1.0/phoenix-core-4.6.0-HBase-1.0.pom
[INFO] Installing 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/target/phoenix-core-4.6.0-HBase-1.0-sources.jar
 to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix-core/4.6.0-HBase-1.0/phoenix-core-4.6.0-HBase-1.0-sources.jar
[INFO] Installing 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-core/target/phoenix-core-4.6.0-HBase-1.0-tests.jar
 to 
/home/jenkins/.m2/repository/org/apache/phoenix/phoenix-core/4.6.0-HBase-1.0/phoenix-core-4.6.0-HBase-1.0-tests.jar
[INFO] 
[INFO] 
[INFO] Building Phoenix - Flume 4.6.0-HBase-1.0
[INFO] 
[INFO] 
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ phoenix-flume ---
[INFO] Deleting 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/target
[INFO] 
[INFO] --- maven-checkstyle-plugin:2.13:check (validate) @ phoenix-flume ---
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-source (add-test-source) @ 
phoenix-flume ---
[INFO] Test Source directory: 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/it/java
 added.
[INFO] 
[INFO] --- build-helper-maven-plugin:1.9.1:add-test-resource 
(add-test-resource) @ phoenix-flume ---
[INFO] 
[INFO] --- maven-remote-resources-plugin:1.5:process (default) @ phoenix-flume 
---
[INFO] 
[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ 
phoenix-flume ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] skip non existing resourceDirectory 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/main/resources
[INFO] Copying 3 resources
[INFO] 
[INFO] --- maven-compiler-plugin:3.0:compile (default-compile) @ phoenix-flume 
---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 9 source files to 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/target/classes
[WARNING] 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/main/java/org/apache/phoenix/flume/sink/PhoenixSink.java:
 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/main/java/org/apache/phoenix/flume/sink/PhoenixSink.java
 uses unchecked or unsafe operations.
[WARNING] 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/main/java/org/apache/phoenix/flume/sink/PhoenixSink.java:
 Recompile with -Xlint:unchecked for details.
[INFO] 
[INFO] --- maven-dependency-plugin:2.1:build-classpath 
(create-mrapp-generated-classpath) @ phoenix-flume ---
[INFO] Wrote classpath file 
'/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/target/classes/mrapp-generated-classpath'.
[INFO] 
[INFO] --- maven-resources-plugin:2.6:testResources (default-testResources) @ 
phoenix-flume ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] skip non existing resourceDirectory 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/test/resources
[INFO] skip non existing resourceDirectory 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/src/it/resources
[INFO] Copying 3 resources
[INFO] 
[INFO] --- maven-compiler-plugin:3.0:testCompile (default-testCompile) @ 
phoenix-flume ---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 4 source files to 
/x1/jenkins/jenkins-slave/workspace/Phoenix-4.x-HBase-1.0/phoenix-flume/target/test-classes
[INFO] 
[INFO] --- maven-surefire-plugin:

Build failed in Jenkins: Phoenix | Master #935

2015-10-22 Thread Apache Jenkins Server 
See 

Changes:

[cmarcel] PHOENIX-2345 - Pherf - ResultManager does not flush

--
[...truncated 6940 lines...]
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec - in 
org.apache.phoenix.expression.function.InstrFunctionTest
Running org.apache.phoenix.expression.StringToArrayFunctionTest
Tests run: 20, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.01 sec - in 
org.apache.phoenix.expression.StringToArrayFunctionTest
Running org.apache.phoenix.expression.NullValueTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.098 sec - in 
org.apache.phoenix.expression.NullValueTest
Running org.apache.phoenix.expression.ExpFunctionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.005 sec - in 
org.apache.phoenix.expression.ExpFunctionTest
Running org.apache.phoenix.expression.CbrtFunctionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.004 sec - in 
org.apache.phoenix.expression.CbrtFunctionTest
Running org.apache.phoenix.expression.RegexpSubstrFunctionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.109 sec - in 
org.apache.phoenix.expression.RegexpSubstrFunctionTest
Running org.apache.phoenix.expression.RegexpReplaceFunctionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.004 sec - in 
org.apache.phoenix.expression.RegexpReplaceFunctionTest
Running org.apache.phoenix.expression.ArrayPrependFunctionTest
Tests run: 37, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.23 sec - in 
org.apache.phoenix.expression.ArrayPrependFunctionTest
Running org.apache.phoenix.expression.DeterminismTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in 
org.apache.phoenix.expression.DeterminismTest
Running org.apache.phoenix.expression.SortOrderExpressionTest
Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.014 sec - in 
org.apache.phoenix.expression.SortOrderExpressionTest
Running org.apache.phoenix.expression.ArithmeticOperationTest
Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.008 sec - in 
org.apache.phoenix.expression.ArithmeticOperationTest
Running org.apache.phoenix.expression.ArrayToStringFunctionTest
Tests run: 24, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.01 sec - in 
org.apache.phoenix.expression.ArrayToStringFunctionTest
Running org.apache.phoenix.expression.OctetLengthFunctionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.014 sec - in 
org.apache.phoenix.expression.OctetLengthFunctionTest
Running org.apache.phoenix.expression.GetSetByteBitFunctionTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.426 sec - in 
org.apache.phoenix.expression.GetSetByteBitFunctionTest
Running org.apache.phoenix.expression.ArrayFillFunctionTest
Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.006 sec - in 
org.apache.phoenix.expression.ArrayFillFunctionTest
Running org.apache.phoenix.expression.ILikeExpressionTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.007 sec - in 
org.apache.phoenix.expression.ILikeExpressionTest
Tests run: 5, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 6.009 sec - in 
org.apache.phoenix.memory.MemoryManagerTest
Running org.apache.phoenix.util.IndexUtilTest
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in 
org.apache.phoenix.util.IndexUtilTest
Running org.apache.phoenix.util.LogUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.053 sec - in 
org.apache.phoenix.util.LogUtilTest
Running org.apache.phoenix.util.QueryUtilTest
Tests run: 9, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec - in 
org.apache.phoenix.util.QueryUtilTest
Running org.apache.phoenix.util.TenantIdByteConversionTest
Tests run: 18, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.004 sec - in 
org.apache.phoenix.util.TenantIdByteConversionTest
Running org.apache.phoenix.util.PropertiesUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.029 sec - in 
org.apache.phoenix.util.PropertiesUtilTest
Running org.apache.phoenix.util.ColumnInfoTest
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.001 sec - in 
org.apache.phoenix.util.ColumnInfoTest
Running org.apache.phoenix.util.csv.CsvUpsertExecutorTest
Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.281 sec - in 
org.apache.phoenix.util.csv.CsvUpsertExecutorTest
Running org.apache.phoenix.util.ByteUtilTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.091 sec - in 
org.apache.phoenix.util.ByteUtilTest
Running org.apache.phoenix.util.LikeExpressionTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0 sec - in 
org.apache.phoenix.util.LikeExpressionTest
Running org.apache.phoenix.util.JDBCUtilTest
Tests run: 11, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.00

phoenix git commit: PHOENIX-2345 - Pherf - ResultManager does not flush

2015-10-22 Thread codymarcel 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 789c96c46 -> 606983425


PHOENIX-2345 - Pherf - ResultManager does not flush


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

Branch: refs/heads/4.x-HBase-1.0
Commit: 6069834254d6ba4c88a2e1786ae9ed9c22a5397f
Parents: 789c96c
Author: cmarcel 
Authored: Thu Oct 22 12:46:31 2015 -0700
Committer: cmarcel 
Committed: Thu Oct 22 15:28:54 2015 -0700

--
 .../phoenix/pherf/result/ResultManager.java | 20 
 .../pherf/workload/MultiThreadedRunner.java |  4 
 .../phoenix/pherf/workload/QueryExecutor.java   |  1 +
 .../org/apache/phoenix/pherf/ResultTest.java|  1 +
 4 files changed, 26 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/60698342/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
index f994621..4d4ca4a 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
@@ -24,11 +24,15 @@ import 
org.apache.phoenix.pherf.result.impl.CSVFileResultHandler;
 import org.apache.phoenix.pherf.result.impl.ImageResultHandler;
 import org.apache.phoenix.pherf.result.impl.XMLResultHandler;
 import org.apache.phoenix.util.InstanceResolver;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
 
 public class ResultManager {
+private static final Logger logger = 
LoggerFactory.getLogger(ResultManager.class);
+
 private final List resultHandlers;
 private final ResultUtil util;
 private static final List defaultHandlers;
@@ -134,6 +138,22 @@ public class ResultManager {
 }
 }
 
+/**
+ * Allows for flushing all the {@link 
org.apache.phoenix.pherf.result.ResultHandler}
+ * @throws Exception
+ */
+public synchronized void flush(){
+for (ResultHandler handler : resultHandlers) {
+try {
+handler.flush();
+} catch (Exception e) {
+e.printStackTrace();
+logger.warn("Could not flush handler: "
++ handler.getResultFileName() + " : " + 
e.getMessage());
+}
+}
+}
+
 public List getResultHandlers() {
 return resultHandlers;
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/60698342/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
index de6cdaf..24c68dc 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
@@ -89,6 +89,10 @@ class MultiThreadedRunner implements Runnable {
 e.printStackTrace();
 }
 }
+
+// Make sure all result have been dumped before exiting
+resultManager.flush();
+
 logger.info("\n\nThread exiting." + threadName + "\n\n");
 }
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/60698342/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
index 347e203..7f861f1 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
@@ -169,6 +169,7 @@ public class QueryExecutor implements Workload {
 resultManager.write(dataModelResult);
 }
 resultManager.write(dataModelResults);
+resultManager.flush();
 } catch (Exception e) {
 logger.warn("", e);
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/60698342/phoenix-pherf/src/test/java/org/apache/phoenix/pherf/ResultTest.java
--

phoenix git commit: PHOENIX-2345 - Pherf - ResultManager does not flush

2015-10-22 Thread codymarcel 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 eb4cb9962 -> c804aa825


PHOENIX-2345 - Pherf - ResultManager does not flush


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

Branch: refs/heads/4.x-HBase-0.98
Commit: c804aa8253be193c1e02b0632c1d0b1d9330b191
Parents: eb4cb99
Author: cmarcel 
Authored: Thu Oct 22 12:46:31 2015 -0700
Committer: cmarcel 
Committed: Thu Oct 22 15:27:54 2015 -0700

--
 .../phoenix/pherf/result/ResultManager.java | 20 
 .../pherf/workload/MultiThreadedRunner.java |  4 
 .../phoenix/pherf/workload/QueryExecutor.java   |  1 +
 .../org/apache/phoenix/pherf/ResultTest.java|  1 +
 4 files changed, 26 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/c804aa82/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
index f994621..4d4ca4a 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
@@ -24,11 +24,15 @@ import 
org.apache.phoenix.pherf.result.impl.CSVFileResultHandler;
 import org.apache.phoenix.pherf.result.impl.ImageResultHandler;
 import org.apache.phoenix.pherf.result.impl.XMLResultHandler;
 import org.apache.phoenix.util.InstanceResolver;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
 
 public class ResultManager {
+private static final Logger logger = 
LoggerFactory.getLogger(ResultManager.class);
+
 private final List resultHandlers;
 private final ResultUtil util;
 private static final List defaultHandlers;
@@ -134,6 +138,22 @@ public class ResultManager {
 }
 }
 
+/**
+ * Allows for flushing all the {@link 
org.apache.phoenix.pherf.result.ResultHandler}
+ * @throws Exception
+ */
+public synchronized void flush(){
+for (ResultHandler handler : resultHandlers) {
+try {
+handler.flush();
+} catch (Exception e) {
+e.printStackTrace();
+logger.warn("Could not flush handler: "
++ handler.getResultFileName() + " : " + 
e.getMessage());
+}
+}
+}
+
 public List getResultHandlers() {
 return resultHandlers;
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c804aa82/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
index de6cdaf..24c68dc 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
@@ -89,6 +89,10 @@ class MultiThreadedRunner implements Runnable {
 e.printStackTrace();
 }
 }
+
+// Make sure all result have been dumped before exiting
+resultManager.flush();
+
 logger.info("\n\nThread exiting." + threadName + "\n\n");
 }
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c804aa82/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
index 347e203..7f861f1 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
@@ -169,6 +169,7 @@ public class QueryExecutor implements Workload {
 resultManager.write(dataModelResult);
 }
 resultManager.write(dataModelResults);
+resultManager.flush();
 } catch (Exception e) {
 logger.warn("", e);
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/c804aa82/phoenix-pherf/src/test/java/org/apache/phoenix/pherf/ResultTest.java

phoenix git commit: PHOENIX-2345 - Pherf - ResultManager does not flush

2015-10-22 Thread codymarcel 
Repository: phoenix
Updated Branches:
  refs/heads/master caa0dbb46 -> 3cbebb8bd


PHOENIX-2345 - Pherf - ResultManager does not flush


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

Branch: refs/heads/master
Commit: 3cbebb8bdb373cc0ac5cb5be0b70b0a5ce061d90
Parents: caa0dbb
Author: cmarcel 
Authored: Thu Oct 22 12:46:31 2015 -0700
Committer: cmarcel 
Committed: Thu Oct 22 15:25:39 2015 -0700

--
 .../phoenix/pherf/result/ResultManager.java | 20 
 .../pherf/workload/MultiThreadedRunner.java |  4 
 .../phoenix/pherf/workload/QueryExecutor.java   |  1 +
 .../org/apache/phoenix/pherf/ResultTest.java|  1 +
 4 files changed, 26 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/3cbebb8b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
index f994621..4d4ca4a 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/result/ResultManager.java
@@ -24,11 +24,15 @@ import 
org.apache.phoenix.pherf.result.impl.CSVFileResultHandler;
 import org.apache.phoenix.pherf.result.impl.ImageResultHandler;
 import org.apache.phoenix.pherf.result.impl.XMLResultHandler;
 import org.apache.phoenix.util.InstanceResolver;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
 
 public class ResultManager {
+private static final Logger logger = 
LoggerFactory.getLogger(ResultManager.class);
+
 private final List resultHandlers;
 private final ResultUtil util;
 private static final List defaultHandlers;
@@ -134,6 +138,22 @@ public class ResultManager {
 }
 }
 
+/**
+ * Allows for flushing all the {@link 
org.apache.phoenix.pherf.result.ResultHandler}
+ * @throws Exception
+ */
+public synchronized void flush(){
+for (ResultHandler handler : resultHandlers) {
+try {
+handler.flush();
+} catch (Exception e) {
+e.printStackTrace();
+logger.warn("Could not flush handler: "
++ handler.getResultFileName() + " : " + 
e.getMessage());
+}
+}
+}
+
 public List getResultHandlers() {
 return resultHandlers;
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3cbebb8b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
index de6cdaf..24c68dc 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/MultiThreadedRunner.java
@@ -89,6 +89,10 @@ class MultiThreadedRunner implements Runnable {
 e.printStackTrace();
 }
 }
+
+// Make sure all result have been dumped before exiting
+resultManager.flush();
+
 logger.info("\n\nThread exiting." + threadName + "\n\n");
 }
 

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3cbebb8b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
--
diff --git 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
index 347e203..7f861f1 100644
--- 
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
+++ 
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
@@ -169,6 +169,7 @@ public class QueryExecutor implements Workload {
 resultManager.write(dataModelResult);
 }
 resultManager.write(dataModelResults);
+resultManager.flush();
 } catch (Exception e) {
 logger.warn("", e);
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/3cbebb8b/phoenix-pherf/src/test/java/org/apache/phoenix/pherf/ResultTest.java