Add parallelism to beam flink

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

@@ -19,11 +19,12 @@ spec:
         - name: jobmanager
           image: uc1-beam-flink:latest # TODO Change when ready
           imagePullPolicy: Never # TODO Change when ready
-          args: ["standalone-job", "--job-classname", "application.Uc1BeamFlink", "--disableMetrics=true", "--fasterCopy"]
+          args: ["standalone-job", "--job-classname", "application.Uc1BeamFlink",
+                  "--parallelism=$(PARALLELISM)",
+                  "--disableMetrics=true",
+                  "--fasterCopy"]
           # optional arguments: ["--job-id", "<job id>", "--fromSavepoint", "/path/to/savepoint", "--allowNonRestoredState"]
           env:
-            # - name: maxSourceParallelism
-            #   value: "1024" 
             - name: KAFKA_BOOTSTRAP_SERVERS
               value: "theodolite-cp-kafka:9092"
             - name: SCHEMA_REGISTRY_URL
@@ -32,8 +33,8 @@ spec:
               value: "100"
             - name: CHECKPOINTING
               value: "false"
-            # - name: PARALLELISM
-            #   value: "2"
+            - name: PARALLELISM
+              value: "1"
             - name: "FLINK_STATE_BACKEND"
               value: "rocksdb"
             - name: JOB_MANAGER_RPC_ADDRESS