[geode-benchmarks] branch develop updated: Fixes parallel task execution.

[jb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jbarrett pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode-benchmarks.git


The following commit(s) were added to refs/heads/develop by this push:
     new cabf106  Fixes parallel task execution.
cabf106 is described below

commit cabf106ca59f8d9c719a15820b3ef1466496a9f3
Author: Jacob Barrett <jb...@pivotal.io>
AuthorDate: Fri Jul 5 15:20:15 2019 -0700

    Fixes parallel task execution.
---
 harness/src/main/java/org/apache/geode/perftest/jvms/RemoteJVMs.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/harness/src/main/java/org/apache/geode/perftest/jvms/RemoteJVMs.java b/harness/src/main/java/org/apache/geode/perftest/jvms/RemoteJVMs.java
index d464ed9..00c40bc 100644
--- a/harness/src/main/java/org/apache/geode/perftest/jvms/RemoteJVMs.java
+++ b/harness/src/main/java/org/apache/geode/perftest/jvms/RemoteJVMs.java
@@ -24,6 +24,7 @@ import java.util.HashSet;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import org.apache.geode.perftest.Task;
@@ -60,7 +61,7 @@ public class RemoteJVMs implements AutoCloseable {
         .filter(mapping -> roles.contains(mapping.getRole()))
         .map(mapping -> controller.onWorker(mapping.getId(), task));
 
-    futures.forEach(CompletableFuture::join);
+    futures.collect(Collectors.toList()).forEach(CompletableFuture::join);
   }
 
   public void close() throws IOException, ExecutionException, InterruptedException {