diff --git a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ScopePassingSpanSubscriber.java b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ScopePassingSpanSubscriber.java index d9b1a806d..63ee1ea7b 100644 --- a/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ScopePassingSpanSubscriber.java +++ b/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/reactor/ScopePassingSpanSubscriber.java @@ -83,15 +83,11 @@ final class ScopePassingSpanSubscriber extends AtomicBoolean implements SpanS } @Override public void onError(Throwable throwable) { - try (Tracer.SpanInScope inScope = this.tracer.withSpanInScope(this.span)) { - this.subscriber.onError(throwable); - } + this.subscriber.onError(throwable); } @Override public void onComplete() { - try (Tracer.SpanInScope inScope = this.tracer.withSpanInScope(this.span)) { - this.subscriber.onComplete(); - } + this.subscriber.onComplete(); } @Override public Context currentContext() {