Optimizing the AggregationTemporality type for Prometheus

jd-opensource · Jan 10, 2025 · af53bb0 · af53bb0
1 parent c54db05
commit af53bb0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...in/java/com/jd/live/agent/implement/event/opentelemetry/oltp/OtlpGrpcExporterFactory.java b/...in/java/com/jd/live/agent/implement/event/opentelemetry/oltp/OtlpGrpcExporterFactory.java
@@ -34,7 +34,7 @@ public class OtlpGrpcExporterFactory implements ExporterFactory {
     public MetricReader create(CounterConfig config) {
         ExporterConfig exporterConfig = config.getExporter();
         MetricExporter exporter = OtlpGrpcMetricExporter.builder().setEndpoint(exporterConfig.getEndpoint()).
-                setAggregationTemporalitySelector(AggregationTemporalitySelector.deltaPreferred()).
+                setAggregationTemporalitySelector(AggregationTemporalitySelector.alwaysCumulative()).
                 setTimeout(Duration.ofMillis(exporterConfig.getTimeout())).build();
         return PeriodicMetricReader.builder(exporter).setInterval(Duration.ofMillis(config.getReaderInterval())).build();
     }

diff --git a/...in/java/com/jd/live/agent/implement/event/opentelemetry/oltp/OtlpHttpExporterFactory.java b/...in/java/com/jd/live/agent/implement/event/opentelemetry/oltp/OtlpHttpExporterFactory.java
@@ -34,7 +34,7 @@ public class OtlpHttpExporterFactory implements ExporterFactory {
     public MetricReader create(CounterConfig config) {
         ExporterConfig exporterConfig = config.getExporter();
         MetricExporter exporter = OtlpHttpMetricExporter.builder().setEndpoint(exporterConfig.getEndpoint()).
-                setAggregationTemporalitySelector(AggregationTemporalitySelector.deltaPreferred()).
+                setAggregationTemporalitySelector(AggregationTemporalitySelector.alwaysCumulative()).
                 setTimeout(Duration.ofMillis(exporterConfig.getTimeout())).build();
         return PeriodicMetricReader.builder(exporter).setInterval(Duration.ofMillis(config.getReaderInterval())).build();
     }