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 03647569555bcf84a84a97cb21e783269b59029e..c9b48c83a995e4d7a12dcbcded223786d803835e 100644 --- a/theodolite-benchmarks/definitions/uc1-beam-flink/resources/jobmanager-deployment.yaml +++ b/theodolite-benchmarks/definitions/uc1-beam-flink/resources/jobmanager-deployment.yaml @@ -20,8 +20,8 @@ spec: image: ghcr.io/cau-se/theodolite-uc1-beam-flink:latest args: ["standalone-job", "--job-classname", "rocks.theodolite.benchmarks.uc1.beam.flink.Uc1BeamFlink", "--parallelism=$(PARALLELISM)", - "--disableMetrics=true", - "--fasterCopy"] + "--disableMetrics=$(DISABLE_METRICS)", + "--fasterCopy=$(FASTER_COPY)"] # optional arguments: ["--job-id", "<job id>", "--fromSavepoint", "/path/to/savepoint", "--allowNonRestoredState"] env: - name: KAFKA_BOOTSTRAP_SERVERS @@ -32,6 +32,10 @@ spec: value: "false" - name: PARALLELISM value: "1" + - name: DISABLE_METRICS + value: "true" + - name: FASTER_COPY + value: "true" - name: "FLINK_STATE_BACKEND" value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS diff --git a/theodolite-benchmarks/definitions/uc2-beam-flink/resources/jobmanager-deployment.yaml b/theodolite-benchmarks/definitions/uc2-beam-flink/resources/jobmanager-deployment.yaml index 961a68acff52f7b300d2049f08652d4251da38a0..27c0a5082ec5e2a5fd0e61800dc6a0429ace8c80 100644 --- a/theodolite-benchmarks/definitions/uc2-beam-flink/resources/jobmanager-deployment.yaml +++ b/theodolite-benchmarks/definitions/uc2-beam-flink/resources/jobmanager-deployment.yaml @@ -20,8 +20,8 @@ spec: image: ghcr.io/cau-se/theodolite-uc2-beam-flink:latest args: ["standalone-job", "--job-classname", "rocks.theodolite.benchmarks.uc2.beam.flink.Uc2BeamFlink", "--parallelism=$(PARALLELISM)", - "--disableMetrics=true", - "--fasterCopy"] + "--disableMetrics=$(DISABLE_METRICS)", + "--fasterCopy=$(FASTER_COPY)"] # optional arguments: ["--job-id", "<job id>", "--fromSavepoint", "/path/to/savepoint", "--allowNonRestoredState"] env: - name: KAFKA_BOOTSTRAP_SERVERS @@ -32,6 +32,10 @@ spec: value: "false" - name: PARALLELISM value: "1" + - name: DISABLE_METRICS + value: "true" + - name: FASTER_COPY + value: "true" - name: "FLINK_STATE_BACKEND" value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS diff --git a/theodolite-benchmarks/definitions/uc3-beam-flink/resources/jobmanager-deployment.yaml b/theodolite-benchmarks/definitions/uc3-beam-flink/resources/jobmanager-deployment.yaml index 62a6d661570f8d25276ac4f04eefbc0e40579fd1..d1b7b9b5166b93325e7b5cb4933d9db5627afcd9 100644 --- a/theodolite-benchmarks/definitions/uc3-beam-flink/resources/jobmanager-deployment.yaml +++ b/theodolite-benchmarks/definitions/uc3-beam-flink/resources/jobmanager-deployment.yaml @@ -20,8 +20,8 @@ spec: image: ghcr.io/cau-se/theodolite-uc3-beam-flink:latest args: ["standalone-job", "--job-classname", "rocks.theodolite.benchmarks.uc3.beam.flink.Uc3BeamFlink", "--parallelism=$(PARALLELISM)", - "--disableMetrics=true", - "--fasterCopy"] + "--disableMetrics=$(DISABLE_METRICS)", + "--fasterCopy=$(FASTER_COPY)"] # optional arguments: ["--job-id", "<job id>", "--fromSavepoint", "/path/to/savepoint", "--allowNonRestoredState"] env: - name: KAFKA_BOOTSTRAP_SERVERS @@ -32,6 +32,10 @@ spec: value: "false" - name: PARALLELISM value: "1" + - name: DISABLE_METRICS + value: "true" + - name: FASTER_COPY + value: "true" - name: "FLINK_STATE_BACKEND" value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS diff --git a/theodolite-benchmarks/definitions/uc4-beam-flink/resources/jobmanager-deployment.yaml b/theodolite-benchmarks/definitions/uc4-beam-flink/resources/jobmanager-deployment.yaml index 4deb0cb21f054bc6f39c4445d5e0411d1d079507..7dbcd62ccd2f99d6a66fc891511f7ebdd1897e51 100644 --- a/theodolite-benchmarks/definitions/uc4-beam-flink/resources/jobmanager-deployment.yaml +++ b/theodolite-benchmarks/definitions/uc4-beam-flink/resources/jobmanager-deployment.yaml @@ -20,8 +20,8 @@ spec: image: ghcr.io/cau-se/theodolite-uc4-beam-flink:latest args: ["standalone-job", "--job-classname", "rocks.theodolite.benchmarks.uc4.beam.flink.Uc4BeamFlink", "--parallelism=$(PARALLELISM)", - "--disableMetrics=true", - "--fasterCopy"] + "--disableMetrics=$(DISABLE_METRICS)", + "--fasterCopy=$(FASTER_COPY)"] # optional arguments: ["--job-id", "<job id>", "--fromSavepoint", "/path/to/savepoint", "--allowNonRestoredState"] env: - name: KAFKA_BOOTSTRAP_SERVERS @@ -32,6 +32,10 @@ spec: value: "false" - name: PARALLELISM value: "1" + - name: DISABLE_METRICS + value: "true" + - name: FASTER_COPY + value: "true" - name: "FLINK_STATE_BACKEND" value: "rocksdb" - name: JOB_MANAGER_RPC_ADDRESS