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/06/16 17:40:32 UTC
[incubator-wayang] 02/03: [WAYANG-30] Missing changes 2 Kafka
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 f2f20f77c377ca5cc20fb167f98baf315e90018c
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Wed Jun 16 13:38:47 2021 -0400
[WAYANG-30] Missing changes 2 Kafka
---
.../hackit/sidecar/webservice/WebService.java | 36 +++++++++++++++++-----
1 file changed, 29 insertions(+), 7 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 7e13f2d..38c8267 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
@@ -52,7 +52,15 @@ public class WebService {
ProcessBuilder builder_proc3 = new ProcessBuilder("kubectl", "create", "-f", path + "jobmanager_new.yaml");
ProcessBuilder builder_proc4 = new ProcessBuilder("kubectl", "create", "-f", path + "jobmanager-service.yaml");
ProcessBuilder builder_proc5 = new ProcessBuilder("kubectl", "create", "-f", path + "taskmanager_new.yaml");
- ProcessBuilder builder_proc6 = new ProcessBuilder("kubectl", "create", "-f", path + "loadbalancer.yaml");
+ //ProcessBuilder builder_proc6 = new ProcessBuilder("kubectl", "create", "-f", path + "loadbalancer.yaml");
+
+ ProcessBuilder builder_proc6 = new ProcessBuilder("kubectl", "create", "namespace", "kafka");
+
+ ProcessBuilder builder_proc7 = new ProcessBuilder("kubectl", "create", "-f", "https://strimzi.io/install/latest?namespace=kafka", "-n", "kafka");
+
+ ProcessBuilder builder_proc8 = new ProcessBuilder("kubectl", "apply", "-f", "https://strimzi.io/examples/latest/kafka/kafka-persistent-single.yaml", "-n", "kafka");
+
+ ProcessBuilder builder_proc9 = new ProcessBuilder("kubectl", "wait", "kafka/my-cluster", "--for=condition=Ready", "--timeout=300s", "-n", "kafka");
List<ProcessBuilder> processes = new ArrayList<>();
processes.add(0, builder_proc1);
@@ -60,7 +68,12 @@ public class WebService {
processes.add(2, builder_proc3);
processes.add(3, builder_proc4);
processes.add(4, builder_proc5);
+ //processes.add(5, builder_proc6);
+
processes.add(5, builder_proc6);
+ processes.add(6, builder_proc7);
+ processes.add(7, builder_proc8);
+ processes.add(8, builder_proc9);
UUID ProcessID = ExecutorManager.addThread(processes);
@@ -154,12 +167,17 @@ public class WebService {
try{
String path = Paths.get(".").toRealPath() + "/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/";
- ProcessBuilder builder_proc1 = new ProcessBuilder("kubectl", "delete", "-f", path + "loadbalancer.yaml");
- ProcessBuilder builder_proc2 = new ProcessBuilder("kubectl", "delete", "-f", path + "jobmanager-service.yaml");
- ProcessBuilder builder_proc3 = new ProcessBuilder("kubectl", "delete", "-f", path + "taskmanager_new.yaml");
- ProcessBuilder builder_proc4 = new ProcessBuilder("kubectl", "delete", "-f", path + "jobmanager_new.yaml");
- ProcessBuilder builder_proc5 = new ProcessBuilder("kubectl", "delete", "-f", path + "claim.yaml");
- ProcessBuilder builder_proc6 = new ProcessBuilder("kubectl", "delete", "-f", path + "volume.yaml");
+ //ProcessBuilder builder_proc1 = new ProcessBuilder("kubectl", "delete", "-f", path + "loadbalancer.yaml");
+ ProcessBuilder builder_proc1 = new ProcessBuilder("kubectl", "delete", "-f", path + "jobmanager-service.yaml");
+ ProcessBuilder builder_proc2 = new ProcessBuilder("kubectl", "delete", "-f", path + "taskmanager_new.yaml");
+ ProcessBuilder builder_proc3 = new ProcessBuilder("kubectl", "delete", "-f", path + "jobmanager_new.yaml");
+ ProcessBuilder builder_proc4 = new ProcessBuilder("kubectl", "delete", "-f", path + "claim.yaml");
+ ProcessBuilder builder_proc5 = new ProcessBuilder("kubectl", "delete", "-f", path + "volume.yaml");
+
+ ProcessBuilder builder_proc6 = new ProcessBuilder("kubectl", "delete", "namespace", "kafka");
+
+ ProcessBuilder builder_proc7 = new ProcessBuilder("kubectl", "delete", "-f", "'https://strimzi.io/install/latest?namespace=kafka'", "-n", "kafka");
+
// For now execute: kubectl port-forward deployment/jobmanager 8081:8081
@@ -169,7 +187,11 @@ public class WebService {
processes.add(2, builder_proc3);
processes.add(3, builder_proc4);
processes.add(4, builder_proc5);
+
+
processes.add(5, builder_proc6);
+ processes.add(6, builder_proc7);
+ //processes.add(5, builder_proc6);
UUID ProcessID = ExecutorManager.addThread(processes);