[FLINK-14663[tests] Support starting individual Job-/TaskManagers

spotify · Nov 15, 2019 · 0d181e9 · 0d181e9
1 parent 2b0a8ce
commit 0d181e9
Showing 1 changed file with 10 additions and 0 deletions.
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
@@ -146,6 +146,16 @@ public void afterTestFailure() {
  afterTestSuccess();
  }
 
+ public void startJobManager() throws IOException {
+ LOG.info("Starting Flink JobManager.");
+ AutoClosableProcess.runBlocking(bin.resolve("jobmanager.sh").toAbsolutePath().toString(), "start");
+ }
+
+ public void startTaskManager() throws IOException {
+ LOG.info("Starting Flink TaskManager.");
+ AutoClosableProcess.runBlocking(bin.resolve("taskmanager.sh").toAbsolutePath().toString(), "start");
+ }
+
  public void startFlinkCluster() throws IOException {
  LOG.info("Starting Flink cluster.");
  AutoClosableProcess.runBlocking(bin.resolve("start-cluster.sh").toAbsolutePath().toString());