From 919827219dd5da4fbcc16a95c40eaa4faa4e57cc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Tue, 20 Jul 2021 19:47:16 +0200
Subject: [PATCH] Fix load generator scaling

---
 .../definitions/uc1-flink/uc1-flink-benchmark-operator.yaml  | 2 ++
 .../definitions/uc1-kstreams/uc1-benchmark-operator.yaml     | 4 ++--
 .../definitions/uc2-flink/uc2-flink-benchmark-operator.yaml  | 2 ++
 .../definitions/uc2-kstreams/uc2-benchmark-operator.yaml     | 2 +-
 .../definitions/uc3-flink/uc3-flink-benchmark-operator.yaml  | 2 ++
 .../definitions/uc3-kstreams/uc3-benchmark-operator.yaml     | 2 +-
 .../definitions/uc4-flink/uc4-flink-benchmark-operator.yaml  | 5 ++++-
 .../definitions/uc4-kstreams/uc4-benchmark-operator.yaml     | 2 +-
 8 files changed, 15 insertions(+), 6 deletions(-)

diff --git a/theodolite-benchmarks/definitions/uc1-flink/uc1-flink-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc1-flink/uc1-flink-benchmark-operator.yaml
index 30e2d6bca..3e16e4864 100644
--- a/theodolite-benchmarks/definitions/uc1-flink/uc1-flink-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc1-flink/uc1-flink-benchmark-operator.yaml
@@ -39,6 +39,8 @@ spec:
             variableName: "NUM_SENSORS"
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc1-kstreams/uc1-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc1-kstreams/uc1-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc1-kstreams/uc1-benchmark-operator.yaml
index 4ec3b08d8..8bcc7d5a1 100644
--- a/theodolite-benchmarks/definitions/uc1-kstreams/uc1-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc1-kstreams/uc1-benchmark-operator.yaml
@@ -24,10 +24,10 @@ spec:
           properties:
             container: "workload-generator"
             variableName: "NUM_SENSORS"
-        - type: "NumSensorsLoadGeneratorReplicaPatcher"
+        - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc1-kstreams/uc1-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc2-flink/uc2-flink-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc2-flink/uc2-flink-benchmark-operator.yaml
index 4bc67808c..ab335cc4f 100644
--- a/theodolite-benchmarks/definitions/uc2-flink/uc2-flink-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc2-flink/uc2-flink-benchmark-operator.yaml
@@ -39,6 +39,8 @@ spec:
             variableName: "NUM_SENSORS"
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc2-kstreams/uc2-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc2-kstreams/uc2-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc2-kstreams/uc2-benchmark-operator.yaml
index aa25c53d7..c71318c95 100644
--- a/theodolite-benchmarks/definitions/uc2-kstreams/uc2-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc2-kstreams/uc2-benchmark-operator.yaml
@@ -27,7 +27,7 @@ spec:
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc2-kstreams/uc2-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc3-flink/uc3-flink-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc3-flink/uc3-flink-benchmark-operator.yaml
index f7a05c137..bc881d83d 100644
--- a/theodolite-benchmarks/definitions/uc3-flink/uc3-flink-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc3-flink/uc3-flink-benchmark-operator.yaml
@@ -39,6 +39,8 @@ spec:
             variableName: "NUM_SENSORS"
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc3-kstreams/uc3-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc3-kstreams/uc3-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc3-kstreams/uc3-benchmark-operator.yaml
index e2679ed86..cc10020b1 100644
--- a/theodolite-benchmarks/definitions/uc3-kstreams/uc3-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc3-kstreams/uc3-benchmark-operator.yaml
@@ -27,7 +27,7 @@ spec:
         - type: NumSensorsLoadGeneratorReplicaPatcher
           resource: "uc3-kstreams/uc3-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc4-flink/uc4-flink-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc4-flink/uc4-flink-benchmark-operator.yaml
index 523167286..9979f540a 100644
--- a/theodolite-benchmarks/definitions/uc4-flink/uc4-flink-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc4-flink/uc4-flink-benchmark-operator.yaml
@@ -37,8 +37,11 @@ spec:
           properties:
             container: "workload-generator"
             variableName: "NUM_NESTED_GROUPS"
-        - type: "NumNestedGroupsLoadGeneratorReplicaPatcher"
+        - type: NumNestedGroupsLoadGeneratorReplicaPatcher
           resource: "uc4-kstreams/uc4-load-generator-deployment.yaml"
+          properties:
+            loadGenMaxRecords: "150000"
+            numSensors: "4.0"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
     topics:
diff --git a/theodolite-benchmarks/definitions/uc4-kstreams/uc4-benchmark-operator.yaml b/theodolite-benchmarks/definitions/uc4-kstreams/uc4-benchmark-operator.yaml
index 3e10fd1ae..61cdfeeea 100644
--- a/theodolite-benchmarks/definitions/uc4-kstreams/uc4-benchmark-operator.yaml
+++ b/theodolite-benchmarks/definitions/uc4-kstreams/uc4-benchmark-operator.yaml
@@ -27,7 +27,7 @@ spec:
         - type: NumNestedGroupsLoadGeneratorReplicaPatcher
           resource: "uc4-kstreams/uc4-load-generator-deployment.yaml"
           properties:
-            loadGenMaxRecords: "15000"
+            loadGenMaxRecords: "150000"
             numSensors: "4.0"
   kafkaConfig:
     bootstrapServer: "theodolite-cp-kafka:9092"
-- 
GitLab