diff --git a/nbr/src/test/java/io/nosqlbench/cli/testing/ExitStatusIntegrationTests.java b/nbr/src/test/java/io/nosqlbench/cli/testing/ExitStatusIntegrationTests.java
index f50704c62..3d0185c04 100644
--- a/nbr/src/test/java/io/nosqlbench/cli/testing/ExitStatusIntegrationTests.java
+++ b/nbr/src/test/java/io/nosqlbench/cli/testing/ExitStatusIntegrationTests.java
@@ -19,40 +19,40 @@ package io.nosqlbench.cli.testing;
 import org.junit.jupiter.api.Test;
 
 import java.util.Optional;
-import java.util.stream.Collectors;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-public class ExitStatusIntegrationTests {
+class ExitStatusIntegrationTests {
 
     private final String java = Optional.ofNullable(System.getenv(
-        "JAVA_HOME")).map(v -> v+"/bin/java").orElse("java");
+            "JAVA_HOME")).map(v -> v + "/bin/java").orElse("java");
 
     private final static String JARNAME = "target/nbr.jar";
+
     @Test
-    public void testExitStatusOnBadParam() {
+    void testExitStatusOnBadParam() {
         ProcessInvoker invoker = new ProcessInvoker();
         invoker.setLogDir("logs/test");
         ProcessResult result = invoker.run("exitstatus_badparam", 15,
                 java, "-jar", JARNAME, "--logs-dir", "logs/test/badparam/",
-            "badparam"
+                "badparam"
         );
         assertThat(result.exception).isNull();
-        String stderr = result.getStderrData().stream().collect(Collectors.joining("\n"));
+        String stderr = String.join("\n", result.getStderrData());
         assertThat(stderr).contains("Scenario stopped due to error");
         assertThat(result.exitStatus).isEqualTo(2);
     }
 
     @Test
-    public void testExitStatusOnActivityInitException() {
+    void testExitStatusOnActivityInitException() {
         ProcessInvoker invoker = new ProcessInvoker();
         invoker.setLogDir("logs/test");
         ProcessResult result = invoker.run("exitstatus_initexception", 15,
                 java, "-jar", JARNAME, "--logs-dir", "logs/test/initerror", "run",
-            "driver=diag", "op=initdelay:initdelay=notanumber"
+                "driver=diag", "op=initdelay:initdelay=notanumber"
         );
         assertThat(result.exception).isNull();
-        String stderr = result.getStdoutData().stream().collect(Collectors.joining("\n"));
+        String stderr = String.join("\n", result.getStdoutData());
         assertThat(stderr).contains("For input string: \"notanumber\"");
         assertThat(result.exitStatus).isEqualTo(2);
     }
@@ -73,19 +73,18 @@ public class ExitStatusIntegrationTests {
 //    }
 
     @Test
-    public void testExitStatusOnActivityOpException() {
+    void testExitStatusOnActivityOpException() {
         ProcessInvoker invoker = new ProcessInvoker();
         invoker.setLogDir("logs/test");
         ProcessResult result = invoker.run("exitstatus_asyncstoprequest", 30,
                 java, "-jar", JARNAME, "--logs-dir", "logs/test/asyncstop", "run",
-            "driver=diag", "cyclerate=5", "op=erroroncycle:erroroncycle=10", "cycles=2000", "-vvv"
+                "driver=diag", "cyclerate=1", "op=erroroncycle:erroroncycle=10", "cycles=2000", "-vvv"
         );
         assertThat(result.exception).isNull();
-        String stdout = result.getStdoutData().stream().collect(Collectors.joining("\n"));
+        String stdout = String.join("\n", result.getStdoutData());
         assertThat(stdout).contains("Diag was requested to stop on cycle 10");
         assertThat(result.exitStatus).isEqualTo(2);
     }
 
 
-
 }