From 558e6408c07ccafd0a46a0e0123d42774b3dcc9f Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Wed, 15 Dec 2021 15:29:13 +0100
Subject: [PATCH] Add MAX_SOURCE_PARALLELISM to beam samza dockerfiles

---
 .../docker-test/uc1-beam-samza/docker-compose.yml                | 1 +
 .../docker-test/uc2-beam-samza/docker-compose.yml                | 1 +
 .../docker-test/uc3-beam-samza/docker-compose.yml                | 1 +
 .../docker-test/uc4-beam-samza/docker-compose.yml                | 1 +
 4 files changed, 4 insertions(+)

diff --git a/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml
index 88cc156ce..40a05a8d1 100644
--- a/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml
@@ -37,6 +37,7 @@ services:
       - schema-registry
       - kafka
     environment:
+      MAX_SOURCE_PARALLELISM: 1
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
   load-generator: 
diff --git a/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml
index 99cd185a8..a9426b907 100644
--- a/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml
@@ -37,6 +37,7 @@ services:
       - schema-registry
       - kafka
     environment:
+      MAX_SOURCE_PARALLELISM: 1
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
       KAFKA_WINDOW_DURATION_MINUTES: 60
diff --git a/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml
index c8fd55e91..c5a55077e 100644
--- a/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml
@@ -37,6 +37,7 @@ services:
       - schema-registry
       - kafka
     environment:
+      MAX_SOURCE_PARALLELISM: 1
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
   load-generator: 
diff --git a/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml
index 806099af1..ac4ab9539 100644
--- a/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml
@@ -37,6 +37,7 @@ services:
       - schema-registry
       - kafka
     environment:
+      MAX_SOURCE_PARALLELISM: 1
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
   load-generator: 
-- 
GitLab