diff --git a/theodolite-benchmarks/uc1-beam-samza/Dockerfile b/theodolite-benchmarks/uc1-beam-samza/Dockerfile index 8519d68153d3341f2f680de6cd4662510c05ac98..30f4981b07de3aed07f2c39dce17859985677809 100644 --- a/theodolite-benchmarks/uc1-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc1-beam-samza/Dockerfile @@ -6,5 +6,10 @@ ENV ENABLE_METRICS=true ADD build/distributions/uc1-beam-samza.tar / ADD samza-standalone.properties / -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\"}" - +CMD JAVA_OPTS="$JAVA_OPTS -Dorg.slf4j.simpleLogger.defaultLogLevel=$LOG_LEVEL" \ + /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\"}" diff --git a/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties index 02411017e86e274f6057688a7c351567603c0f80..a4c778604bf10b46ad22095070bc2886d7868467 100644 --- a/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties @@ -15,3 +15,7 @@ systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.consumer.bootstrap.servers=localhost:9092 systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 + +# Configure JMX metrics exporter +metrics.reporter.jmx.class=org.apache.samza.metrics.reporter.JmxReporterFactory +metrics.reporters=jmx diff --git a/theodolite-benchmarks/uc2-beam-samza/Dockerfile b/theodolite-benchmarks/uc2-beam-samza/Dockerfile index f873ec8cba111e70dfdb29ae20dc4fbb2e7a9ecc..7d69fde4ff338b1bed2dbb6e951e0d63573c7841 100644 --- a/theodolite-benchmarks/uc2-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc2-beam-samza/Dockerfile @@ -6,4 +6,11 @@ ENV ENABLE_METRICS=true ADD build/distributions/uc2-beam-samza.tar / ADD samza-standalone.properties / -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\"}" +CMD JAVA_OPTS="$JAVA_OPTS -Dorg.slf4j.simpleLogger.defaultLogLevel=$LOG_LEVEL" \ + /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\"}" + diff --git a/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties index 02411017e86e274f6057688a7c351567603c0f80..a4c778604bf10b46ad22095070bc2886d7868467 100644 --- a/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties @@ -15,3 +15,7 @@ systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.consumer.bootstrap.servers=localhost:9092 systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 + +# Configure JMX metrics exporter +metrics.reporter.jmx.class=org.apache.samza.metrics.reporter.JmxReporterFactory +metrics.reporters=jmx diff --git a/theodolite-benchmarks/uc3-beam-samza/Dockerfile b/theodolite-benchmarks/uc3-beam-samza/Dockerfile index 02ac459e5197fc0d66bb0d70840a88d32d8084c3..781dd2eb1ec3ae8c373f1f12878fbc65f6491176 100644 --- a/theodolite-benchmarks/uc3-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc3-beam-samza/Dockerfile @@ -6,4 +6,11 @@ ENV ENABLE_METRICS=true ADD build/distributions/uc3-beam-samza.tar / ADD samza-standalone.properties / -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\"}" + +CMD JAVA_OPTS="$JAVA_OPTS -Dorg.slf4j.simpleLogger.defaultLogLevel=$LOG_LEVEL" \ + /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\"}" diff --git a/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties index 02411017e86e274f6057688a7c351567603c0f80..a4c778604bf10b46ad22095070bc2886d7868467 100644 --- a/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties @@ -15,3 +15,7 @@ systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.consumer.bootstrap.servers=localhost:9092 systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 + +# Configure JMX metrics exporter +metrics.reporter.jmx.class=org.apache.samza.metrics.reporter.JmxReporterFactory +metrics.reporters=jmx diff --git a/theodolite-benchmarks/uc4-beam-samza/Dockerfile b/theodolite-benchmarks/uc4-beam-samza/Dockerfile index 92a400d15d7726dc948cfd7df7e6e4ee7fd76812..9cee781f13d97c824b11f416e1b49255ef118baf 100644 --- a/theodolite-benchmarks/uc4-beam-samza/Dockerfile +++ b/theodolite-benchmarks/uc4-beam-samza/Dockerfile @@ -6,4 +6,10 @@ ENV ENABLE_METRICS=true ADD build/distributions/uc4-beam-samza.tar / ADD samza-standalone.properties / -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\"}" +CMD JAVA_OPTS="$JAVA_OPTS -Dorg.slf4j.simpleLogger.defaultLogLevel=$LOG_LEVEL" \ + /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\"}" diff --git a/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties index 812a9784c25ea84922b8a0f96f17b0377cedf925..edcc3a98583f6ea3540e8a6759d8521d5cf2337f 100644 --- a/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties @@ -16,6 +16,10 @@ systems.kafka.consumer.bootstrap.servers=localhost:9092 systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 +# Configure JMX metrics exporter +metrics.reporter.jmx.class=org.apache.samza.metrics.reporter.JmxReporterFactory +metrics.reporters=jmx + # Configure serialization and stores serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory stores.my-store.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory