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/18 22:17:31 UTC
[incubator-wayang] branch debugger-sidecar updated (89ce68e ->
0324067)
This is an automated email from the ASF dual-hosted git repository.
rpardomeza pushed a change to branch debugger-sidecar
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git.
from 89ce68e [WAYANG-30] Function to check Thread status
new aa7289d [WAYANG-30] Persistent Volume objects for testing
new 7f0ea3b [WAYANG-30] Flink cluster submitting plan testing
new 27d601c [WAYANG-30] Maven configuration fixes
new 0324067 [WAYANG-30] Adjustment to create/delete flink cluster
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../wayang-hackit/wayang-hackit-sidecar/pom.xml | 16 +-
.../org/apache/wayang/hackit/sidecar/test.java | 225 +++++++++++++++++++++
.../hackit/sidecar/webservice/WebService.java | 75 ++++++-
.../src/main/resources/claim.yaml | 11 +
.../{jobmanager.yaml => jobmanager_new.yaml} | 9 +-
.../src/main/resources/loadbalancer.yaml | 14 ++
.../{taskmanager.yaml => taskmanager_new.yaml} | 9 +-
.../src/main/resources/volume.yaml | 14 ++
8 files changed, 360 insertions(+), 13 deletions(-)
create mode 100644 wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/test.java
create mode 100644 wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/claim.yaml
copy wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/{jobmanager.yaml => jobmanager_new.yaml} (73%)
create mode 100644 wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/loadbalancer.yaml
copy wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/{taskmanager.yaml => taskmanager_new.yaml} (72%)
create mode 100644 wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/volume.yaml
[incubator-wayang] 01/04: [WAYANG-30] Persistent Volume objects for
testing
Posted by rp...@apache.org.
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 aa7289df469ab044bd64c5fc85b8073078977eb8
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Tue May 18 18:14:05 2021 -0400
[WAYANG-30] Persistent Volume objects for testing
---
.../src/main/resources/claim.yaml | 11 ++++++
.../src/main/resources/jobmanager_new.yaml | 40 ++++++++++++++++++++++
.../src/main/resources/loadbalancer.yaml | 14 ++++++++
.../src/main/resources/taskmanager_new.yaml | 38 ++++++++++++++++++++
.../src/main/resources/volume.yaml | 14 ++++++++
5 files changed, 117 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/claim.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/claim.yaml
new file mode 100644
index 0000000..f1de882
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/claim.yaml
@@ -0,0 +1,11 @@
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+ name: task-pv-claim
+spec:
+ storageClassName: manual
+ accessModes:
+ - ReadWriteMany
+ resources:
+ requests:
+ storage: 1Gi
\ No newline at end of file
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager_new.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager_new.yaml
new file mode 100644
index 0000000..8ab2f48
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/jobmanager_new.yaml
@@ -0,0 +1,40 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+ name: jobmanager
+spec:
+ selector:
+ matchLabels:
+ app: flink
+ replicas: 1
+ template:
+ metadata:
+ labels:
+ app: flink
+ component: master
+ spec:
+ volumes:
+ - name: task-pv-storage
+ persistentVolumeClaim:
+ claimName: task-pv-claim
+ containers:
+ - name: master
+ image: flink:1.13.0-scala_2.11-java8
+ workingDir: /opt/flink
+ args:
+ - jobmanager
+ ports:
+ - containerPort: 6123
+ name: rpc
+ - containerPort: 6124
+ name: blob
+ - containerPort: 6125
+ name: query
+ - containerPort: 6126
+ name: ui
+ env:
+ - name: JOB_MANAGER_RPC_ADDRESS
+ value: jobmanager
+ volumeMounts:
+ - mountPath: "/mnt/example"
+ name: task-pv-storage
\ No newline at end of file
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/loadbalancer.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/loadbalancer.yaml
new file mode 100644
index 0000000..e0625f4
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/loadbalancer.yaml
@@ -0,0 +1,14 @@
+apiVersion: v1
+kind: Service
+metadata:
+ name: jobmanager-loadbalancer
+ labels:
+ app: jobmanager-loadbalancer
+spec:
+ ports:
+ - name: http
+ port: 8081
+ targetPort: 8081
+ selector:
+ app: jobmanager
+ type: LoadBalancer
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/taskmanager_new.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/taskmanager_new.yaml
new file mode 100644
index 0000000..6344a15
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/taskmanager_new.yaml
@@ -0,0 +1,38 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+ name: taskmanager
+spec:
+ selector:
+ matchLabels:
+ app: flink
+ replicas: 2
+ template:
+ metadata:
+ labels:
+ app: flink
+ component: task
+ spec:
+ volumes:
+ - name: task-pv-storage
+ persistentVolumeClaim:
+ claimName: task-pv-claim
+ containers:
+ - name: task
+ image: flink:1.13.0-scala_2.11-java8
+ workingDir: /opt/flink
+ args:
+ - taskmanager
+ ports:
+ - containerPort: 6121
+ name: data
+ - containerPort: 6122
+ name: rpc
+ - containerPort: 6125
+ name: query
+ env:
+ - name: JOB_MANAGER_RPC_ADDRESS
+ value: jobmanager
+ volumeMounts:
+ - mountPath: "/mnt/example"
+ name: task-pv-storage
\ No newline at end of file
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/volume.yaml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/volume.yaml
new file mode 100644
index 0000000..9d328c1
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/resources/volume.yaml
@@ -0,0 +1,14 @@
+apiVersion: v1
+kind: PersistentVolume
+metadata:
+ name: task-pv-volume
+ labels:
+ type: local
+spec:
+ storageClassName: manual
+ capacity:
+ storage: 3Gi
+ accessModes:
+ - ReadWriteMany
+ hostPath:
+ path: "/Users/rodrigopardomeza/flink"
\ No newline at end of file
[incubator-wayang] 04/04: [WAYANG-30] Adjustment to create/delete
flink cluster
Posted by rp...@apache.org.
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 03240679ebbc91af376eb3cee863463d82cbc470
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Tue May 18 18:17:06 2021 -0400
[WAYANG-30] Adjustment to create/delete flink cluster
---
.../hackit/sidecar/webservice/WebService.java | 75 +++++++++++++++++++---
1 file changed, 67 insertions(+), 8 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 38a5003..93f4818 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
@@ -9,12 +9,11 @@ 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.apache.wayang.core.util.ReflectionUtils;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.*;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.UUID;
+import java.util.*;
@RestController
@RequestMapping("/sidecar")
@@ -41,14 +40,18 @@ public class WebService {
@GetMapping("/debug/start")
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");
+ ProcessBuilder builder_proc1 = new ProcessBuilder("kubectl", "create", "-f", "volume.yaml");
+ ProcessBuilder builder_proc2 = new ProcessBuilder("kubectl", "create", "-f", "claim.yaml");
+ ProcessBuilder builder_proc3 = new ProcessBuilder("kubectl", "create", "-f", "jobmanager_new.yaml");
+ ProcessBuilder builder_proc4 = new ProcessBuilder("kubectl", "create", "-f", "jobmanager-service.yaml");
+ ProcessBuilder builder_proc5 = new ProcessBuilder("kubectl", "create", "-f", "taskmanger_new.yaml");
List<ProcessBuilder> processes = new ArrayList<>();
processes.add(0, builder_proc1);
processes.add(1, builder_proc2);
processes.add(2, builder_proc3);
+ processes.add(3, builder_proc4);
+ processes.add(4, builder_proc5);
UUID ProcessID = ExecutorManager.addThread(processes);
@@ -80,12 +83,68 @@ public class WebService {
return HttpStatus.ACCEPTED;
}
- @GetMapping("/debug/stop")
- public HttpStatus serviceStop(){
+ @GetMapping("/debug/plan/run")
+ public HttpStatus planRun(){
+
+ try {
+ // LocalEnvironment
+ ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("127.0.0.1", 8081);
+
+ //ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("127.0.0.1", 57261, getJars());
+ //DataSet<String> data = env.readTextFile("file:///Users/rodrigopardomeza/flink/count");
+ DataSet<String> data = env.readTextFile("/mnt/example/count");
+
+ data
+ /*.filter(new FilterFunction<String>() {
+ public boolean filter(String value) {
+ return value.startsWith("T");
+ }
+ })*/
+ .writeAsText("/mnt/example/output_z");
+
+ JobExecutionResult res = env.execute();
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
return HttpStatus.ACCEPTED;
}
+ private String[] getJars(){
+ List<String> jars = new ArrayList<>(5);
+ List<Class> clazzs = Arrays.asList(new Class[]{this.getClass()});
+
+ clazzs.stream().map(
+ ReflectionUtils::getDeclaringJar
+ ).filter(
+ element -> element != null
+ ).forEach(jars::add);
+
+ return jars.toArray(new String[0]);
+ }
+
+ @GetMapping("/debug/stop")
+ public UUID serviceStop(){
+
+ ProcessBuilder builder_proc1 = new ProcessBuilder("kubectl", "delete", "-f", "volume.yaml");
+ ProcessBuilder builder_proc2 = new ProcessBuilder("kubectl", "delete", "-f", "claim.yaml");
+ ProcessBuilder builder_proc3 = new ProcessBuilder("kubectl", "delete", "-f", "jobmanager_new.yaml");
+ ProcessBuilder builder_proc4 = new ProcessBuilder("kubectl", "delete", "-f", "jobmanager-service.yaml");
+ ProcessBuilder builder_proc5 = new ProcessBuilder("kubectl", "delete", "-f", "taskmanger_new.yaml");
+
+ List<ProcessBuilder> processes = new ArrayList<>();
+ processes.add(0, builder_proc1);
+ processes.add(1, builder_proc2);
+ processes.add(2, builder_proc3);
+ processes.add(3, builder_proc4);
+ processes.add(4, builder_proc5);
+
+ UUID ProcessID = ExecutorManager.addThread(processes);
+
+ return ProcessID;
+ }
+
@PostMapping(path = "/debug/check")
public String checkStatus(
@RequestParam("key") String key,
[incubator-wayang] 02/04: [WAYANG-30] Flink cluster submitting plan
testing
Posted by rp...@apache.org.
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 7f0ea3be052aefb4ba059d7b72776da190f32f18
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Tue May 18 18:15:19 2021 -0400
[WAYANG-30] Flink cluster submitting plan testing
---
.../org/apache/wayang/hackit/sidecar/test.java | 225 +++++++++++++++++++++
1 file changed, 225 insertions(+)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/test.java b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/test.java
new file mode 100644
index 0000000..816384a
--- /dev/null
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/src/main/java/org/apache/wayang/hackit/sidecar/test.java
@@ -0,0 +1,225 @@
+package org.apache.wayang.hackit.sidecar;
+
+import org.apache.flink.api.common.functions.FilterFunction;
+import org.apache.flink.api.common.functions.FlatMapFunction;
+import org.apache.flink.api.java.DataSet;
+import org.apache.flink.api.java.ExecutionEnvironment;
+import org.apache.flink.util.Collector;
+import org.reflections.Reflections;
+
+import java.io.*;
+import java.net.URI;
+import java.net.URL;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.*;
+import java.util.function.Function;
+import java.util.jar.JarOutputStream;
+import java.util.jar.JarEntry;
+import java.util.zip.ZipEntry;
+
+public class test {
+
+ public static void main(String... args) throws Exception {
+ System.out.println(Arrays.toString(getJars()));
+ ExecutionEnvironment env = ExecutionEnvironment
+ .createRemoteEnvironment(
+ "127.0.0.1",
+ 8081,
+ //"/Users/rodrigopardomeza/tu-berlin/debugger/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/target/wayang-hackit-sidecar-0.6.0-SNAPSHOT.jar"
+ getJars()
+ );
+
+ String clusterPath = "/mnt/example/";
+ //DataSet<String> data = env.readTextFile("/Users/rodrigopardomeza/flink/count");
+ //DataSet<String> data = env.readTextFile(clusterPath + "count");
+ DataSet<String> data = env.readTextFile("/mnt/example/count");
+
+ System.out.println(data.count());
+
+ DataSet<String> words = data.flatMap(
+ /*(FlatMapFunction<String, String>) (s,l) -> {
+ for (String ss : s.split(" ")) {
+ l.collect(ss);
+ }
+ }*/
+ new FlatMapFunction<String, String>() {
+ @Override
+ public void flatMap(String s, Collector<String> collector) throws Exception {
+ String[] wor = s.split(" ");
+ for (String ss: wor
+ ) {
+ collector.collect(ss);
+ }
+ }
+ }
+
+ );
+ Function<Integer, Integer> lala = a -> a + 2;
+ DataSet<String> data2 = words
+ .filter((FilterFunction<String>) value -> value.startsWith("T"));
+ /*DataSet<String> words = data.flatMap(
+ new FlatMapFunction<String, String>() {
+ @Override
+ public void flatMap(String s, Collector<String> collector) throws Exception {
+ String[] wor = s.split(" ");
+ for (String ss: wor
+ ) {
+ collector.collect(ss);
+ }
+ }
+ }
+
+ );*/
+ //.filter(line -> line.startsWith("T"))
+ data2.writeAsText( "/mnt/example/cluster_4", org.apache.flink.core.fs.FileSystem.WriteMode.OVERWRITE);
+ //.writeAsText("/Users/rodrigopardomeza/flink/cluster_babe");
+
+ env.execute();
+
+ }
+
+ private static String[] getJars(){
+ List<String> jars = new ArrayList<>(5);
+ List<Class> clazzs = Arrays.asList(new Class[]{test.class});
+
+ clazzs.stream().map(
+ test::getDeclaringJar
+ ).filter(
+ element -> element != null
+ ).forEach(jars::add);
+
+ return jars.toArray(new String[0]);
+ }
+
+ public static String getDeclaringJar(Class<?> cls) {
+ try {
+ final URL location = cls.getProtectionDomain().getCodeSource().getLocation();
+ final URI uri = location.toURI();
+ String path = uri.getPath();
+ if (path.endsWith(".jar")) {
+ return path;
+ } else {
+ System.out.println(
+ String.format(
+ "Class %s is not loaded from a JAR file, but from %s. Thus, cannot provide the JAR file.",
+ cls,
+ path
+ )
+ );
+ path = createJAR(cls);
+ return path;
+ }
+ } catch (Exception e) {
+ System.out.println(
+ String.format(
+ "Could not determine JAR file declaring %s.",
+ cls
+ )
+ );
+ }
+ return null;
+ }
+
+ public static String createJAR(Class clazz){
+ try {
+ Path tmpCustomPrefix = Files.createTempDirectory("lala");
+ String path_final = tmpCustomPrefix.toString() + "/lala.jar";
+ //String path_final = "/Users/rodrigopardomeza/tu-berlin/debugger/lala.jar";
+ System.out.println(path_final);
+
+ FileOutputStream fout = new FileOutputStream(path_final);
+ JarOutputStream jarOut = new JarOutputStream(fout);
+
+
+ Class[] clazzs = getClasses(clazz.getPackage().getName());
+
+ for(int i = 0; i < clazzs.length; i++){
+ addClass(clazzs[i], jarOut);
+ }
+
+
+
+ jarOut.close();
+ fout.close();
+ return path_final;
+
+ } catch (Exception e){
+
+ }
+ return null;
+ }
+
+ private static void addClass(Class c, JarOutputStream jarOutputStream) throws IOException {
+ String path = c.getName().replace('.', '/') + ".class";
+ jarOutputStream.putNextEntry(new JarEntry(path));
+ jarOutputStream.write(toByteArray(c.getClassLoader().getResourceAsStream(path)));
+ jarOutputStream.closeEntry();
+ }
+
+ public static byte[] toByteArray(InputStream in) throws IOException {
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+ byte[] buf = new byte[0x1000];
+ while (true) {
+ int r = in.read(buf);
+ if (r == -1) {
+ break;
+ }
+ out.write(buf, 0, r);
+ }
+ return out.toByteArray();
+ }
+
+ /**
+ * Scans all classes accessible from the context class loader which belong to the given package and subpackages.
+ *
+ * @param packageName The base package
+ * @return The classes
+ * @throws ClassNotFoundException
+ * @throws IOException
+ */
+ private static Class[] getClasses(String packageName)
+ throws ClassNotFoundException, IOException {
+ ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
+ assert classLoader != null;
+ String path = packageName.replace('.', '/');
+ Enumeration<URL> resources = classLoader.getResources(path);
+ List<File> dirs = new ArrayList<File>();
+ while (resources.hasMoreElements()) {
+ URL resource = resources.nextElement();
+ dirs.add(new File(resource.getFile()));
+ }
+ ArrayList<Class> classes = new ArrayList<Class>();
+ for (File directory : dirs) {
+ classes.addAll(findClasses(directory, packageName));
+ }
+ return classes.toArray(new Class[classes.size()]);
+ }
+
+ /**
+ * Recursive method used to find all classes in a given directory and subdirs.
+ *
+ * @param directory The base directory
+ * @param packageName The package name for classes found inside the base directory
+ * @return The classes
+ * @throws ClassNotFoundException
+ */
+ private static List<Class> findClasses(File directory, String packageName) throws ClassNotFoundException {
+ List<Class> classes = new ArrayList<Class>();
+ if (!directory.exists()) {
+ return classes;
+ }
+ File[] files = directory.listFiles();
+ for (File file : files) {
+ //if (file.isDirectory()) {
+ // assert !file.getName().contains(".");
+ // classes.addAll(findClasses(file, packageName + "." + file.getName()));
+ //} else
+ if (file.getName().endsWith(".class")) {
+ classes.add(Class.forName(packageName + '.' + file.getName().substring(0, file.getName().length() - 6)));
+ }
+ }
+ return classes;
+ }
+}
+
[incubator-wayang] 03/04: [WAYANG-30] Maven configuration fixes
Posted by rp...@apache.org.
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 27d601c5ec97d2cc3386f0df4988e35d7a0856f1
Author: rodrigopardomeza <ro...@gmail.com>
AuthorDate: Tue May 18 18:15:52 2021 -0400
[WAYANG-30] Maven configuration fixes
---
.../wayang-hackit/wayang-hackit-sidecar/pom.xml | 16 +++++++++++++---
1 file changed, 13 insertions(+), 3 deletions(-)
diff --git a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/pom.xml b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/pom.xml
index 6a6004d..3a75d61 100644
--- a/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/pom.xml
+++ b/wayang-plugins/wayang-hackit/wayang-hackit-sidecar/pom.xml
@@ -21,7 +21,7 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
- <artifactId>wayang</artifactId>
+ <artifactId>wayang-hackit</artifactId>
<groupId>org.apache.wayang</groupId>
<version>0.6.0-SNAPSHOT</version>
</parent>
@@ -30,8 +30,8 @@
<artifactId>wayang-hackit-sidecar</artifactId>
<properties>
- <maven.compiler.source>11</maven.compiler.source>
- <maven.compiler.target>11</maven.compiler.target>
+ <maven.compiler.source>8</maven.compiler.source>
+ <maven.compiler.target>8</maven.compiler.target>
</properties>
<dependencyManagement>
@@ -62,6 +62,16 @@
<artifactId>flink-clients_2.11</artifactId>
<version>1.13.0</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.wayang</groupId>
+ <artifactId>wayang-core</artifactId>
+ <version>0.6.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.reflections</groupId>
+ <artifactId>reflections</artifactId>
+ <version>0.9.12</version>
+ </dependency>
</dependencies>
<build>