You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/20 13:53:39 UTC
[rocketmq-clients] branch master updated: Using default aggregationTemporalitySelector (#67)
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 8d873be Using default aggregationTemporalitySelector (#67)
8d873be is described below
commit 8d873be40c53e9ff374f9e07514c2a3e7f827ed7
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Wed Jul 20 21:53:34 2022 +0800
Using default aggregationTemporalitySelector (#67)
---
.../org/apache/rocketmq/client/java/metrics/ClientMeterProvider.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterProvider.java b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterProvider.java
index 16804b9..532b787 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterProvider.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterProvider.java
@@ -31,7 +31,6 @@ import io.opentelemetry.sdk.metrics.InstrumentSelector;
import io.opentelemetry.sdk.metrics.InstrumentType;
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
import io.opentelemetry.sdk.metrics.View;
-import io.opentelemetry.sdk.metrics.export.AggregationTemporalitySelector;
import io.opentelemetry.sdk.metrics.export.PeriodicMetricReader;
import io.opentelemetry.sdk.resources.Resource;
import java.net.InetSocketAddress;
@@ -99,7 +98,6 @@ public class ClientMeterProvider {
ManagedChannel channel = channelBuilder.build();
OtlpGrpcMetricExporter exporter = OtlpGrpcMetricExporter.builder().setChannel(channel)
.setTimeout(METRIC_EXPORTER_RPC_TIMEOUT)
- .setAggregationTemporalitySelector(AggregationTemporalitySelector.deltaPreferred())
.build();
InstrumentSelector sendSuccessCostTimeInstrumentSelector = InstrumentSelector.builder()