open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use BatchSpanProcessor (#5275)

This commit is contained in:
Trask Stalnaker 2022-01-31 09:14:03 -08:00 committed by GitHub
parent 236a42f111
commit 3bee90a69b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
instrumentation/spring/spring-boot-autoconfigure/src/main/java/io/opentelemetry/instrumentation/spring/autoconfigure/OpenTelemetryAutoConfiguration.java
View File

@ -11,7 +11,7 @@ import io.opentelemetry.context.propagation.ContextPropagators;
import io.opentelemetry.sdk.OpenTelemetrySdk; import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.trace.SdkTracerProvider; import io.opentelemetry.sdk.trace.SdkTracerProvider;
import io.opentelemetry.sdk.trace.SdkTracerProviderBuilder; import io.opentelemetry.sdk.trace.SdkTracerProviderBuilder;
import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor; import io.opentelemetry.sdk.trace.export.BatchSpanProcessor;
import io.opentelemetry.sdk.trace.export.SpanExporter; import io.opentelemetry.sdk.trace.export.SpanExporter;
import io.opentelemetry.sdk.trace.samplers.Sampler; import io.opentelemetry.sdk.trace.samplers.Sampler;
import java.util.Collections; import java.util.Collections;
@ -45,8 +45,7 @@ public class OpenTelemetryAutoConfiguration {
SdkTracerProviderBuilder tracerProviderBuilder = SdkTracerProvider.builder(); SdkTracerProviderBuilder tracerProviderBuilder = SdkTracerProvider.builder();
spanExportersProvider.getIfAvailable(Collections::emptyList).stream() spanExportersProvider.getIfAvailable(Collections::emptyList).stream()
// todo SimpleSpanProcessor...is that really what we want here? .map(spanExporter -> BatchSpanProcessor.builder(spanExporter).build())
.map(SimpleSpanProcessor::create)
.forEach(tracerProviderBuilder::addSpanProcessor); .forEach(tracerProviderBuilder::addSpanProcessor);
return tracerProviderBuilder return tracerProviderBuilder