[FLINK-16188][e2e] AutoClosableProcess constructor now private

spotify · Feb 23, 2020 · 40c0ba3 · 40c0ba3
1 parent 0aa296c
commit 40c0ba3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/...nd-to-end-tests-common/src/main/java/org/apache/flink/tests/util/AutoClosableProcess.java b/...nd-to-end-tests-common/src/main/java/org/apache/flink/tests/util/AutoClosableProcess.java
@@ -46,7 +46,7 @@ public class AutoClosableProcess implements AutoCloseable {
 
  private final Process process;
 
- public AutoClosableProcess(final Process process) {
+ private AutoClosableProcess(final Process process) {
  Preconditions.checkNotNull(process);
  this.process = process;
  }

diff --git a/...-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/FlinkDistribution.java b/...-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/FlinkDistribution.java
@@ -205,9 +205,7 @@ public JobID submitJob(final JobSubmission jobSubmission) throws IOException {
 
  LOG.info("Running {}.", commands.stream().collect(Collectors.joining(" ")));
 
- try (AutoClosableProcess flink = new AutoClosableProcess(new ProcessBuilder()
- .command(commands)
- .start())) {
+ try (AutoClosableProcess flink = AutoClosableProcess.runNonBlocking(commands.toArray(String[]::new))) {
 
  final Pattern pattern = jobSubmission.isDetached()
  ? Pattern.compile("Job has been submitted with JobID (.*)")