[BEAM-4176] Adding start method back to the FlinkJobserverDriver

je-ik · Oct 16, 2018 · ae34c93 · ae34c93
1 parent b40c276
commit ae34c93
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java
@@ -170,6 +170,11 @@ public void run() {
     }
   }
 
+  public String start() throws IOException {
+    jobServer = createJobServer();
+    return jobServer.getApiServiceDescriptor().getUrl();
+  }
+
   public void stop() {
     if (jobServer != null) {
       try {