diff --git a/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/MetricEmitter.java b/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/MetricEmitter.java index 83d2b7650..fe9877b43 100644 --- a/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/MetricEmitter.java +++ b/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/MetricEmitter.java @@ -22,7 +22,7 @@ @Log4j2 public abstract class MetricEmitter implements Emitter { - protected static final long FLUSH_INTERVAL = 5000; + protected static final long FLUSH_INTERVAL = 1000; protected static final String DIMENSION_API_NAME = "apiName"; protected static final String DIMENSION_STATUS_CODE = "statusCode"; protected static String API_COUNTER_METRIC = "apiBytesSent"; diff --git a/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/OtlpMetricEmitter.java b/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/OtlpMetricEmitter.java index 9058d5bf7..d8cfd8ef9 100644 --- a/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/OtlpMetricEmitter.java +++ b/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/OtlpMetricEmitter.java @@ -64,7 +64,7 @@ public void nextDataPoint() { } break; case "gauge": - for (int i = 0; i < param.getRate() * 5; i++) { + for (int i = 0; i < param.getRate(); i++) { this.gaugeValues[i] = ThreadLocalRandom.current().nextLong(-100, 100); } break; @@ -105,8 +105,8 @@ public void setupProvider() { private void createCounters(Meter meter) { if (meter != null) { log.info("Registering counter metrics..."); - counters = new LongCounter[param.getRate() * 5]; - for (int i = 0; i < param.getRate() * 5; i++) { + counters = new LongCounter[param.getRate()]; + for (int i = 0; i < param.getRate(); i++) { counters[i] = meter.counterBuilder(API_COUNTER_METRIC + i) .setDescription("API request load sent in bytes") .setUnit("one") @@ -120,7 +120,7 @@ private void createCounters(Meter meter) { private void createGauges(Meter meter) { if (meter != null) { log.info("Registering gauge metrics..."); - gaugeValues = new long[param.getRate() * 5]; + gaugeValues = new long[param.getRate()]; int id = 0; for (long gaugeValue : gaugeValues) { meter.gaugeBuilder(API_LATENCY_METRIC + id++) diff --git a/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/StatsdMetricEmitter.java b/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/StatsdMetricEmitter.java index a9caa5034..f1f954459 100644 --- a/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/StatsdMetricEmitter.java +++ b/load-generator/src/main/java/com/amazon/opentelemetry/load/generator/emitter/StatsdMetricEmitter.java @@ -67,7 +67,7 @@ public void sendStatsd() throws IOException { payload = new StringBuilder(); String attributes = "#mykey:myvalue,datapoint_id:"; log.debug("Updating metrics..."); - for (int i = 0; i < this.param.getRate() * 5; i++) { + for (int i = 0; i < this.param.getRate(); i++) { payload.append("statsdTestMetric").append(i).append(":") .append(ThreadLocalRandom.current().nextInt(-100, 100)) .append("|g|").append(attributes).append(i).append("\n"); diff --git a/terraform/testcases/prometheus_mock/otconfig.tpl b/terraform/testcases/prometheus_mock/otconfig.tpl index 31e3fa493..0c48b6250 100644 --- a/terraform/testcases/prometheus_mock/otconfig.tpl +++ b/terraform/testcases/prometheus_mock/otconfig.tpl @@ -5,7 +5,7 @@ receivers: prometheus: config: global: - scrape_interval: 15s + scrape_interval: 1s scrape_configs: - job_name: "test-pipeline-job" static_configs: