Add --maxSourceParallelism to dockerfiles for beam

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
 

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
 

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

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

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

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

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

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