diff --git a/theodolite-benchmarks/definitions/uc1-beam-flink/resources/jobmanager-deployment.yaml b/theodolite-benchmarks/definitions/uc1-beam-flink/resources/jobmanager-deployment.yaml index ef07c2996df53dc25e46563e0b6dea97b6abab45..3258d9e2df0f9dba008678b559a70c2166ec31f9 100644 --- a/theodolite-benchmarks/definitions/uc1-beam-flink/resources/jobmanager-deployment.yaml +++ b/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