From ab03f6f49d7f0c2af634ad7a536e546d2870ac98 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Fri, 25 Nov 2022 19:19:03 +0100
Subject: [PATCH] Add smoketest for UC3 Flink
---
.gitlab-ci.yml | 10 ++++++++++
theodolite-benchmarks/docker-test/uc3-flink/test.sh | 11 +++++++++++
2 files changed, 21 insertions(+)
create mode 100755 theodolite-benchmarks/docker-test/uc3-flink/test.sh
diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
index 0b8a87bb3..37826729b 100644
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -573,6 +573,16 @@ smoketest-uc3-kstreams:
DOCKER_COMPOSE_DIR: "uc3-kstreams"
JAVA_PROJECT_DEPS: "uc3-kstreams,kstreams-commons,uc3-load-generator,load-generator-commons"
+smoketest-uc3-flink:
+ extends: .smoketest-benchmarks
+ needs:
+ - deploy-uc3-flink
+ - deploy-uc3-load-generator
+ variables:
+ DOCKER_COMPOSE_DIR: "uc3-flink"
+ JAVA_PROJECT_DEPS: "uc3-flink,flink-commons,uc3-load-generator,load-generator-commons"
+
+
smoketest-uc3-beam-flink:
extends: .smoketest-benchmarks
needs:
diff --git a/theodolite-benchmarks/docker-test/uc3-flink/test.sh b/theodolite-benchmarks/docker-test/uc3-flink/test.sh
new file mode 100755
index 000000000..217a730f7
--- /dev/null
+++ b/theodolite-benchmarks/docker-test/uc3-flink/test.sh
@@ -0,0 +1,11 @@
+#!/bin/sh
+
+until docker-compose exec -T kcat kcat -L -b kafka:9092 -t output -J | jq -r '.topics[0].partitions | length' | grep "\b3\b"; do sleep 5s; done
+
+docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 600 |
+ tee /dev/stderr |
+ awk -F ':' '!/^%/ {print $1}' |
+ sort |
+ uniq |
+ wc -l |
+ grep "\b10\b"
\ No newline at end of file
--
GitLab