Skip to content
Snippets Groups Projects
Commit 744d55b5 authored by Sören Henning's avatar Sören Henning
Browse files

Make Samza metrics configurable

parent afc0d400
No related branches found
No related tags found
No related merge requests found
Pipeline #10216 passed
...@@ -25,6 +25,8 @@ spec: ...@@ -25,6 +25,8 @@ spec:
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: MAX_SOURCE_PARALLELISM - name: MAX_SOURCE_PARALLELISM
value: "1024" value: "1024"
- name: ENABLE_METRICS
value: "false"
- name: KAFKA_BOOTSTRAP_SERVERS - name: KAFKA_BOOTSTRAP_SERVERS
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: SCHEMA_REGISTRY_URL - name: SCHEMA_REGISTRY_URL
......
...@@ -25,6 +25,8 @@ spec: ...@@ -25,6 +25,8 @@ spec:
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: MAX_SOURCE_PARALLELISM - name: MAX_SOURCE_PARALLELISM
value: "1024" value: "1024"
- name: ENABLE_METRICS
value: "false"
- name: KAFKA_BOOTSTRAP_SERVERS - name: KAFKA_BOOTSTRAP_SERVERS
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: SCHEMA_REGISTRY_URL - name: SCHEMA_REGISTRY_URL
......
...@@ -25,6 +25,8 @@ spec: ...@@ -25,6 +25,8 @@ spec:
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: MAX_SOURCE_PARALLELISM - name: MAX_SOURCE_PARALLELISM
value: "1024" value: "1024"
- name: ENABLE_METRICS
value: "false"
- name: KAFKA_BOOTSTRAP_SERVERS - name: KAFKA_BOOTSTRAP_SERVERS
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: SCHEMA_REGISTRY_URL - name: SCHEMA_REGISTRY_URL
......
...@@ -25,6 +25,8 @@ spec: ...@@ -25,6 +25,8 @@ spec:
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: MAX_SOURCE_PARALLELISM - name: MAX_SOURCE_PARALLELISM
value: "1024" value: "1024"
- name: ENABLE_METRICS
value: "false"
- name: KAFKA_BOOTSTRAP_SERVERS - name: KAFKA_BOOTSTRAP_SERVERS
value: "theodolite-kafka-kafka-bootstrap:9092" value: "theodolite-kafka-kafka-bootstrap:9092"
- name: SCHEMA_REGISTRY_URL - name: SCHEMA_REGISTRY_URL
......
FROM openjdk:11-slim FROM openjdk:11-slim
ENV MAX_SOURCE_PARALLELISM=1024 ENV MAX_SOURCE_PARALLELISM=1024
ENV ENABLE_METRICS=true
ADD build/distributions/uc1-beam-samza.tar / ADD build/distributions/uc1-beam-samza.tar /
ADD samza-standalone.properties / ADD samza-standalone.properties /
CMD /uc1-beam-samza/bin/uc1-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}" CMD /uc1-beam-samza/bin/uc1-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=$ENABLE_METRICS --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}"
FROM openjdk:11-slim FROM openjdk:11-slim
ENV MAX_SOURCE_PARALLELISM=1024 ENV MAX_SOURCE_PARALLELISM=1024
ENV ENABLE_METRICS=true
ADD build/distributions/uc2-beam-samza.tar / ADD build/distributions/uc2-beam-samza.tar /
ADD samza-standalone.properties / ADD samza-standalone.properties /
CMD /uc2-beam-samza/bin/uc2-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}" CMD /uc2-beam-samza/bin/uc2-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=$ENABLE_METRICS --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}"
FROM openjdk:11-slim FROM openjdk:11-slim
ENV MAX_SOURCE_PARALLELISM=1024 ENV MAX_SOURCE_PARALLELISM=1024
ENV ENABLE_METRICS=true
ADD build/distributions/uc3-beam-samza.tar / ADD build/distributions/uc3-beam-samza.tar /
ADD samza-standalone.properties / ADD samza-standalone.properties /
CMD /uc3-beam-samza/bin/uc3-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}" CMD /uc3-beam-samza/bin/uc3-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=$ENABLE_METRICS --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}"
FROM openjdk:11-slim FROM openjdk:11-slim
ENV MAX_SOURCE_PARALLELISM=1024 ENV MAX_SOURCE_PARALLELISM=1024
ENV ENABLE_METRICS=true
ADD build/distributions/uc4-beam-samza.tar / ADD build/distributions/uc4-beam-samza.tar /
ADD samza-standalone.properties / ADD samza-standalone.properties /
CMD /uc4-beam-samza/bin/uc4-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=false --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}" CMD /uc4-beam-samza/bin/uc4-beam-samza --configFilePath=samza-standalone.properties --samzaExecutionEnvironment=STANDALONE --maxSourceParallelism=$MAX_SOURCE_PARALLELISM --enableMetrics=$ENABLE_METRICS --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}"
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment