diff --git a/theodolite-benchmarks/uc1-beam-flink/Dockerfile b/theodolite-benchmarks/uc1-beam-flink/Dockerfile index 99afa663aef13098ae9745742dd6dcc43a3dd0fa..26f25c9dee8e4efe52861278b99a1f7ecd0ece3b 100644 --- a/theodolite-benchmarks/uc1-beam-flink/Dockerfile +++ b/theodolite-benchmarks/uc1-beam-flink/Dockerfile @@ -2,5 +2,5 @@ FROM openjdk:11-slim ADD build/distributions/uc1-beam-flink.tar / -CMD /uc1-beam-flink/bin/uc1-beam-flink --runner=FlinkRunner --streaming --disableMetrics=true --fasterCopy +CMD /uc1-beam-flink/bin/uc1-beam-flink --runner=FlinkRunner --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --streaming --disableMetrics=true --fasterCopy diff --git a/theodolite-benchmarks/uc1-beam-samza/Dockerfile b/theodolite-benchmarks/uc1-beam-samza/Dockerfile index 75571f382cea7da371a70b28fd693e599c3b526a..d8b6447e11a0131a771ae188215b8507b2e2e99b 100644 --- a/theodolite-benchmarks/uc1-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc1-beam-samza/Dockerfile @@ -3,5 +3,5 @@ FROM openjdk:11-slim ADD build/distributions/uc1-beam-samza.tar / ADD samza-standalone.properties / -CMD /uc1-beam-samza/bin/uc1-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --enableMetrics=false +CMD /uc1-beam-samza/bin/uc1-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false diff --git a/theodolite-benchmarks/uc2-beam-flink/Dockerfile b/theodolite-benchmarks/uc2-beam-flink/Dockerfile index 7e2396c57e67c120215689e5ead23e2525c3d8a3..75c4882280b30a584b0d8a350a6571d8201591dc 100644 --- a/theodolite-benchmarks/uc2-beam-flink/Dockerfile +++ b/theodolite-benchmarks/uc2-beam-flink/Dockerfile @@ -2,4 +2,4 @@ FROM openjdk:11-slim ADD build/distributions/uc2-beam-flink.tar / -CMD /uc2-beam-flink/bin/uc2-beam-flink --runner=FlinkRunner --streaming --disableMetrics=true --fasterCopy +CMD /uc2-beam-flink/bin/uc2-beam-flink --runner=FlinkRunner --flinkMaster=flink-jobmanager:8081 --streaming --parallelism=$PARALLELISM --disableMetrics=true --fasterCopy diff --git a/theodolite-benchmarks/uc2-beam-samza/Dockerfile b/theodolite-benchmarks/uc2-beam-samza/Dockerfile index bb517b9e2b1021ad75c1f6714ca9afecfcbbd154..2edb7c18208f6b60e0b904c05037b6cf4654ee90 100644 --- a/theodolite-benchmarks/uc2-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc2-beam-samza/Dockerfile @@ -3,4 +3,4 @@ FROM openjdk:11-slim ADD build/distributions/uc2-beam-samza.tar / ADD samza-standalone.properties / -CMD /uc2-beam-samza/bin/uc2-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --enableMetrics=false +CMD /uc2-beam-samza/bin/uc2-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false diff --git a/theodolite-benchmarks/uc3-beam-flink/Dockerfile b/theodolite-benchmarks/uc3-beam-flink/Dockerfile index c8eeb48557cdc9cb9aac238ff73af62581c9e4e0..87285a07f7765818ea48d9f4faf6755f8a98f15c 100644 --- a/theodolite-benchmarks/uc3-beam-flink/Dockerfile +++ b/theodolite-benchmarks/uc3-beam-flink/Dockerfile @@ -2,4 +2,4 @@ FROM openjdk:11-slim ADD build/distributions/uc3-beam-flink.tar / -CMD /uc3-beam-flink/bin/uc3-beam-flink --runner=FlinkRunner --streaming --disableMetrics=true --fasterCopy --stateBackend=rocksdb --stateBackendStoragePath=file:///data/flink/checkpoints +CMD /uc3-beam-flink/bin/uc3-beam-flink --runner=FlinkRunner --flinkMaster=flink-jobmanager:8081 --streaming --parallelism=$PARALLELISM --disableMetrics=true --fasterCopy --stateBackend=rocksdb --stateBackendStoragePath=file:///data/flink/checkpoints diff --git a/theodolite-benchmarks/uc3-beam-samza/Dockerfile b/theodolite-benchmarks/uc3-beam-samza/Dockerfile index 3e68ef01d7a927c93c782c6990f114b8d286f476..4e8e9d999fc9ee35f6b7c35043e47b33f0950b3f 100644 --- a/theodolite-benchmarks/uc3-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc3-beam-samza/Dockerfile @@ -3,4 +3,4 @@ FROM openjdk:11-slim ADD build/distributions/uc3-beam-samza.tar / ADD samza-standalone.properties / -CMD /uc3-beam-samza/bin/uc3-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --enableMetrics=false +CMD /uc3-beam-samza/bin/uc3-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false diff --git a/theodolite-benchmarks/uc4-beam-flink/Dockerfile b/theodolite-benchmarks/uc4-beam-flink/Dockerfile index 4892ff32f6b96785f1345851bd19980331c3bc92..f8b9cbf52a1fded814b0ba5bd85bbec4f02db759 100644 --- a/theodolite-benchmarks/uc4-beam-flink/Dockerfile +++ b/theodolite-benchmarks/uc4-beam-flink/Dockerfile @@ -2,4 +2,4 @@ FROM openjdk:11-slim ADD build/distributions/uc4-beam-flink.tar / -CMD /uc4-beam-flink/bin/uc4-beam-flink --runner=FlinkRunner --streaming --disableMetrics=true --fasterCopy --stateBackend=rocksdb --stateBackendStoragePath=file:///data/flink/checkpoints +CMD /uc4-beam-flink/bin/uc4-beam-flink --runner=FlinkRunner --flinkMaster=flink-jobmanager:8081 --streaming --parallelism=$PARALLELISM --disableMetrics=true --fasterCopy --stateBackend=rocksdb --stateBackendStoragePath=file:///data/flink/checkpoints diff --git a/theodolite-benchmarks/uc4-beam-samza/Dockerfile b/theodolite-benchmarks/uc4-beam-samza/Dockerfile index e7f4e10b5ea5829bc7e1d4b545718d5be19760a4..cb6a1f5fdbd0e19feabeb948d869ac4be1681d36 100644 --- a/theodolite-benchmarks/uc4-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc4-beam-samza/Dockerfile @@ -3,4 +3,4 @@ FROM openjdk:11-slim ADD build/distributions/uc4-beam-samza.tar / ADD samza-standalone.properties / -CMD /uc4-beam-samza/bin/uc4-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --enableMetrics=false +CMD /uc4-beam-samza/bin/uc4-beam-samza --configFactory=org.apache.samza.config.factories.PropertiesConfigFactory --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false