You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by rp...@apache.org on 2021/05/17 20:14:25 UTC
[incubator-wayang] 03/04: [WAYANG-30] Function to start Flink
Cluster
This is an automated email from the ASF dual-hosted git repository.
rpardomeza pushed a commit to branch debugger-sidecar
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit a0e7988555113acaaf3d6d1a1ccc2d0c148169f4
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Mon May 17 16:12:45 2021 -0400
[WAYANG-30] Function to start Flink Cluster
---
.../hackit/sidecar/webservice/WebService.java | 32 +++++++++++++++++++---
1 file changed, 28 insertions(+), 4 deletions(-)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/webservice/WebService.java b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/webservice/WebService.java
index 850edee..b463b59 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/webservice/WebService.java
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/webservice/WebService.java
@@ -4,10 +4,17 @@ import org.apache.flink.api.common.JobExecutionResult;
import org.apache.flink.api.common.functions.FilterFunction;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
+import org.apache.flink.api.java.operators.ProjectOperator;
+import org.apache.flink.api.java.tuple.Tuple;
+import org.apache.flink.api.java.tuple.Tuple2;
+import org.apache.flink.api.java.tuple.Tuple3;
+import org.apache.flink.api.java.tuple.Tuple4;
import org.springframework.http.HttpStatus;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
@RestController
@RequestMapping("/sidecar")
@@ -32,7 +39,24 @@ public class WebService {
}
@GetMapping("/debug/start")
- public HttpStatus serviceStart(){
+ public UUID serviceStart(){
+
+ ProcessBuilder builder_proc1 = new ProcessBuilder("kubectl", "create", "-f", "jobmanager.yaml");
+ ProcessBuilder builder_proc2 = new ProcessBuilder("kubectl", "create", "-f", "jobmanager-service.yaml");
+ ProcessBuilder builder_proc3 = new ProcessBuilder("kubectl", "create", "-f", "taskmanger.yaml");
+
+ List<ProcessBuilder> processes = new ArrayList<>();
+ processes.add(0, builder_proc1);
+ processes.add(1, builder_proc2);
+ processes.add(2, builder_proc3);
+
+ UUID ProcessID = ExecutorManager.addThread(processes);
+
+ return ProcessID;
+ }
+
+ @GetMapping("/debug/demo")
+ public HttpStatus serviceDemo(){
try {
// LocalEnvironment