helm/templates/grafana/dashboard-config-map.yaml

@@ -24,7 +24,7 @@ data:
     "editable": true,
     "gnetId": null,
     "graphTooltip": 0,
-    "id": 2,
+    "id": 1,
     "iteration": 1589140028684,
     "links": [],
     "panels": [
@@ -1004,4 +1004,4 @@ data:
     "uid": "dad0CNlZz",
     "version": 25
     }`}}
-{{- end }}
\ No newline at end of file
+{{- end }}

theodolite-benchmarks/definitions/uc1-flink/resources/jobmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: jobmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: jobmanager
           image: ghcr.io/cau-se/theodolite-uc1-flink:latest
@@ -90,4 +91,4 @@ spec:
           emptyDir: {}
 #        - name: job-artifacts-volume
 #          hostPath:
-#            path: /host/path/to/job/artifacts
\ No newline at end of file
+#            path: /host/path/to/job/artifacts

theodolite-benchmarks/definitions/uc1-flink/resources/taskmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: taskmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: taskmanager
           image: ghcr.io/cau-se/theodolite-uc1-flink:latest

theodolite-benchmarks/definitions/uc2-flink/resources/jobmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: jobmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: jobmanager
           image: ghcr.io/cau-se/theodolite-uc2-flink:latest
@@ -90,4 +91,4 @@ spec:
           emptyDir: {}
 #        - name: job-artifacts-volume
 #          hostPath:
-#            path: /host/path/to/job/artifacts
\ No newline at end of file
+#            path: /host/path/to/job/artifacts

theodolite-benchmarks/definitions/uc2-flink/resources/taskmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: taskmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: taskmanager
           image: ghcr.io/cau-se/theodolite-uc2-flink:latest

theodolite-benchmarks/definitions/uc3-flink/resources/jobmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: jobmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: jobmanager
           image: ghcr.io/cau-se/theodolite-uc3-flink:latest
@@ -90,4 +91,4 @@ spec:
           emptyDir: {}
 #        - name: job-artifacts-volume
 #          hostPath:
-#            path: /host/path/to/job/artifacts
\ No newline at end of file
+#            path: /host/path/to/job/artifacts

theodolite-benchmarks/definitions/uc3-flink/resources/taskmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: taskmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: taskmanager
           image: ghcr.io/cau-se/theodolite-uc3-flink:latest

theodolite-benchmarks/definitions/uc4-flink/resources/jobmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: jobmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: jobmanager
           image: ghcr.io/cau-se/theodolite-uc4-flink:latest
@@ -90,4 +91,4 @@ spec:
           emptyDir: {}
 #        - name: job-artifacts-volume
 #          hostPath:
-#            path: /host/path/to/job/artifacts
\ No newline at end of file
+#            path: /host/path/to/job/artifacts

theodolite-benchmarks/definitions/uc4-flink/resources/taskmanager-deployment.yaml

@@ -14,6 +14,7 @@ spec:
         app: flink
         component: taskmanager
     spec:
+      terminationGracePeriodSeconds: 0
       containers:
         - name: taskmanager
           image: ghcr.io/cau-se/theodolite-uc4-flink:latest

theodolite/src/main/kotlin/theodolite/execution/operator/ExecutionEventHandler.kt

@@ -80,7 +80,7 @@ class ExecutionHandler(
     override fun onDelete(execution: ExecutionCRD, b: Boolean) {
         logger.info { "Delete execution ${execution.metadata.name}" }
         if (execution.status.executionState == States.RUNNING.value
-            && this.controller.isExecutionRunning(execution.spec.name)
+            && this.controller.isExecutionRunning(execution.metadata.name)
         ) {
             this.controller.stop()
         }