diff --git a/theodolite-benchmarks/docker-test/uc1-beam-flink/docker-compose.yml b/theodolite-benchmarks/docker-test/uc1-beam-flink/docker-compose.yml index fcfc15d7fe4da72dcf29d5d747f8a47efa9fefeb..2cd36a39b8016bc50b0e0fb61e0f40345d888d8b 100644 --- a/theodolite-benchmarks/docker-test/uc1-beam-flink/docker-compose.yml +++ b/theodolite-benchmarks/docker-test/uc1-beam-flink/docker-compose.yml @@ -1,4 +1,4 @@ -version: '2' +version: '2.2' services: zookeeper: image: confluentinc/cp-zookeeper @@ -63,6 +63,7 @@ services: - kafka benchmark-taskmanager: image: uc1-beam-flink:latest + scale: 1 command: taskmanager environment: - | diff --git a/theodolite-benchmarks/docker-test/uc2-beam-flink/docker-compose.yml b/theodolite-benchmarks/docker-test/uc2-beam-flink/docker-compose.yml index 0327a0e3870c54962b8d62bae4945cbb3341d769..d60624365221f3e81cbad889f7f32836ddf349de 100644 --- a/theodolite-benchmarks/docker-test/uc2-beam-flink/docker-compose.yml +++ b/theodolite-benchmarks/docker-test/uc2-beam-flink/docker-compose.yml @@ -1,4 +1,4 @@ -version: '2' +version: '2.2' services: zookeeper: image: confluentinc/cp-zookeeper @@ -64,6 +64,7 @@ services: - kafka benchmark-taskmanager: image: uc2-beam-flink:latest + scale: 1 command: taskmanager environment: - | diff --git a/theodolite-benchmarks/docker-test/uc3-beam-flink/docker-compose.yml b/theodolite-benchmarks/docker-test/uc3-beam-flink/docker-compose.yml index 3dd8115fcfb250aaade27d7ac30f945614ef6555..6d674755962ef30b873884aeec3327786a1b908d 100644 --- a/theodolite-benchmarks/docker-test/uc3-beam-flink/docker-compose.yml +++ b/theodolite-benchmarks/docker-test/uc3-beam-flink/docker-compose.yml @@ -1,4 +1,4 @@ -version: '2' +version: '2.2' services: zookeeper: image: confluentinc/cp-zookeeper @@ -51,8 +51,6 @@ services: --streaming --disableMetrics=true --fasterCopy - --stateBackend=rocksdb - --stateBackendStoragePath=file:///data/flink/checkpoints environment: - KAFKA_BOOTSTRAP_SERVERS=kafka:9092 - SCHEMA_REGISTRY_URL=http://schema-registry:8081 @@ -60,16 +58,21 @@ services: FLINK_PROPERTIES= jobmanager.rpc.address: benchmark-jobmanager parallelism.default: 1 + state.backend: rocksdb + state.checkpoints.dir: file:///data/flink/checkpoints depends_on: - schema-registry - kafka benchmark-taskmanager: image: uc3-beam-flink:latest + scale: 1 command: taskmanager environment: - | FLINK_PROPERTIES= jobmanager.rpc.address: benchmark-jobmanager + state.backend: rocksdb + state.checkpoints.dir: file:///data/flink/checkpoints depends_on: - schema-registry - kafka diff --git a/theodolite-benchmarks/docker-test/uc4-beam-flink/docker-compose.yml b/theodolite-benchmarks/docker-test/uc4-beam-flink/docker-compose.yml index e32bf9f4d6df5ca8b6ddee144c54398762d3d442..0c6fb34a3ad4523cafd6b1a4d66e7bfa17fe81d9 100644 --- a/theodolite-benchmarks/docker-test/uc4-beam-flink/docker-compose.yml +++ b/theodolite-benchmarks/docker-test/uc4-beam-flink/docker-compose.yml @@ -1,4 +1,4 @@ -version: '2' +version: '2.2' services: zookeeper: image: confluentinc/cp-zookeeper @@ -53,8 +53,6 @@ services: --streaming --disableMetrics=true --fasterCopy - --stateBackend=rocksdb - --stateBackendStoragePath=file:///data/flink/checkpoints environment: - KAFKA_BOOTSTRAP_SERVERS=kafka:9092 - SCHEMA_REGISTRY_URL=http://schema-registry:8081 @@ -62,16 +60,21 @@ services: FLINK_PROPERTIES= jobmanager.rpc.address: benchmark-jobmanager parallelism.default: 1 + state.backend: rocksdb + state.checkpoints.dir: file:///data/flink/checkpoints depends_on: - schema-registry - kafka benchmark-taskmanager: image: uc4-beam-flink:latest command: taskmanager + scale: 1 environment: - | FLINK_PROPERTIES= jobmanager.rpc.address: benchmark-jobmanager + state.backend: rocksdb + state.checkpoints.dir: file:///data/flink/checkpoints depends_on: - schema-registry - kafka