helm/README.md

@@ -47,7 +47,7 @@ helm install theodolite . -f preconfigs/one-broker-values.yaml
 To uninstall/delete the `theodolite` deployment:
 
 ```sh
-helm delete theodolite
+helm uninstall theodolite
 ```
 
 This command does not remove the CRDs which are created by this chart. Remove them manually with:

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()
         }

theodolite/src/main/kotlin/theodolite/patcher/PatcherFactory.kt

@@ -32,7 +32,7 @@ class PatcherFactory {
             k8sResources.filter { it.first == patcherDefinition.resource }
                 .map { resource -> resource.second }
                 .firstOrNull()
-                ?: throw DeploymentFailedException("Could not find resource ${patcherDefinition.resource}")
+                ?: throw InvalidPatcherConfigurationException("Could not find resource ${patcherDefinition.resource}")
 
         return try {
             when (patcherDefinition.type) {
@@ -86,10 +86,10 @@ class PatcherFactory {
                 )
                 else -> throw InvalidPatcherConfigurationException("Patcher type ${patcherDefinition.type} not found.")
             }
-        } catch (e: Exception) {
+        } catch (e: NullPointerException) {
             throw InvalidPatcherConfigurationException(
                 "Could not create patcher with type ${patcherDefinition.type}" +
-                        " Probably a required patcher argument was not specified."
+                        " Probably a required patcher argument was not specified.", e
             )
         }
     }

theodolite/src/main/kotlin/theodolite/util/InvalidPatcherConfigurationException.kt

 package theodolite.util
 
-class InvalidPatcherConfigurationException(message: String) : Exception(message)
+class InvalidPatcherConfigurationException(message: String, e: Exception? = null) : Exception(message, e)