diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml index 0b8a87bb35ddfabf966e59b9e43af639e0b7fe41..37826729b815d0390d0e64d8c0409a2f9fa90f13 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 0000000000000000000000000000000000000000..217a730f73fa1fee3f875da34edd9047ed9221db --- /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