diff --git a/testutils/ptest2/src/main/java/org/apache/hive/ptest/execution/Phase.java b/testutils/ptest2/src/main/java/org/apache/hive/ptest/execution/Phase.java
index aee09b348595..47633ec44818 100644
--- a/testutils/ptest2/src/main/java/org/apache/hive/ptest/execution/Phase.java
+++ b/testutils/ptest2/src/main/java/org/apache/hive/ptest/execution/Phase.java
@@ -94,7 +94,7 @@ protected List<SSHResult> execHostsIgnoreErrors(String command)
     for(HostExecutor hostExecutor : hostExecutors) {
       futures.add(hostExecutor.execIgnoreAllErrors(command));
     }
-    return toListOfResults(futures);
+    return toListOfResults(futures, false);
   }
   // clean prep
   protected List<RemoteCommandResult> execInstances(String command)
@@ -167,10 +167,15 @@ private <T extends RemoteCommandResult> List<T> flatten(List<ListenableFuture<Li
   }
   private <T extends RemoteCommandResult> List<T> toListOfResults(List<ListenableFuture<T>> futures)
       throws Exception {
+    return toListOfResults(futures, true);
+  }
+  private <T extends RemoteCommandResult> List<T> toListOfResults(List<ListenableFuture<T>> futures,
+      boolean reportErrors)
+      throws Exception {
     List<T> results = Lists.newArrayList();
     for(T result : Futures.allAsList(futures).get()) {
       if(result != null) {
-        if(result.getException() != null || result.getExitCode() != 0) {
+        if(reportErrors && (result.getException() != null || result.getExitCode() != 0)) {
           throw new SSHExecutionException(result);
         }
         results.add(result);