gRPC server instrumentations (grpc-1.5, armeria-grpc) don't make extracted W3C baggage current in the handler
Maintainer antworten meist innerhalb von 2 Tagen
@mcculls arbeitet bereits daran.
Seit 28.9.2026.
Bewertung
- Schwierigkeit
- 3/5
- Geschätzter Aufwand
- 1-2 Tage
- Anfängerfreundlichkeit
- 78/100
- Issue-Typ
- Bug
- Klarheit
- Klar beschrieben
- Aktivitätsstatus
- Aktiv
- Tech-Stack
- grpc, java
- Bereich
- observability
Rechercherichtung
Start with the extraction and activation paths in dd-java-agent/instrumentation/grpc-1.5/.../TracingServerInterceptor.java and the corresponding armeria-grpc-0.84 file, then run the GrpcServerBaggageTest reproduction. Compare them with HttpServerDecorator and JettyServerAdvice; done means inbound baggage is current in the unary handler and is reinjected on outbound calls while trace propagation still works.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Beschreibung
Tracer Version(s)
1.56.0, 1.66.0 (observed); master at 02d50d2 (code reading)
Java Version(s)
17.0.13
JVM Vendor
Eclipse Adoptium / Temurin
Bug Report
gRPC server instrumentations (grpc-1.5 and armeria-grpc-0.84) extract inbound W3C baggage but don't make it current while the service runs. As a result:
Baggage.current()(OTel API,DD_TRACE_OTEL_ENABLED=true) is empty inside the handler.- Downstream calls from the handler carry no
baggageheader, even though the trace context (x-datadog-*,traceparent) propagates fine.
The baggage.* span tags still show up on the grpc.server span, which makes the loss easy to miss.
Root cause. Both TracingServerInterceptors call the deprecated AgentPropagation.extractContextAndGetSpanContext (internal-api, v1.66.0 L33-L38).
- That helper extracts the full
Contextand then returns only the span context, so the extractedBaggageelement is discarded. - The interceptor then runs
next.startCall(...)and every listener callback underactivateSpan(span), which is a span-only context. - The tags appear anyway because
BaggagePropagator.extractalso copies the baggage onto the extractedTagContext(v1.66.0 L130-L138).
Call sites:
armeria-grpc-0.84: extract L71, activate L94grpc-1.5: extract L72, activate L95
HTTP servers don't have this problem. They were moved to full-context extraction in #8820: HttpServerDecorator.extract returns the whole Context, and e.g. JettyServerAdvice attaches parentContext.with(span) (v1.66.0 L32-L61).
Observed (dd-java-agent 1.56.0 and 1.66.0; Armeria 1.33.4 and 1.41.0). An agent-less client sends baggage: jtbd=ap.curl,user.id=u1 plus x-datadog-* headers to a relay server, whose handler logs Baggage.current() and makes one outbound OkHttp call:
| relay server | Baggage.current() in handler (OTel bridge on) |
baggage header on the relay's outbound call |
baggage.jtbd tag on server span |
trace joins |
|---|---|---|---|---|
Armeria GrpcService |
{} |
none | yes | yes |
| Jetty 11 servlet | {jtbd=ap.curl, user.id=u1} |
jtbd=ap.curl,user.id=u1 |
yes | yes |
The result was the same with the OTel bridge unset, apart from the Baggage.current() column, which the bridge feeds. I did not run a grpc-java (Netty) server in that harness. For grpc-1.5, the unit test below reproduces the same loss.
Other callers of the deprecated helper (master at 02d50d2, non-test code). I found these by reading the code and have not reproduced them. They look like they have the same shape: extract, keep only the span context, then activate a span-only context.
- RPC:
sofarpc-5.0(ProviderProxyInvokerInstrumentation) - Messaging consumers:
kafka-clients-0.11andkafka-clients-3.8(TracingIterator),aws-java-sqs-1.0andaws-java-sqs-2.0(TracingIterator),javax-jms-1.1(JMSMessageConsumerInstrumentation,DatadogMessageListener),rabbitmq-amqp-2.7(RabbitDecorator),google-pubsub-1.116(PubSubDecorator) - API shims:
opentracing-0.31/0.32(OTTracer),opentelemetry-0.3(OtelContextPropagators)
I've seen #11286 and the note there that W3C baggage was initially scoped to HTTP. gRPC carries baggage as an HTTP/2 header, and these servers already extract and tag it, so it seemed worth reporting on its own. Please relabel as a feature request if that fits your conventions better.
Expected Behavior
When a gRPC server span is started from extracted headers, the rest of the extracted context (W3C baggage) is current for the whole call, as it is for HTTP servers. In particular:
Baggage.current()in the service implementation returns the inbound members.- Outbound calls made from the handler re-inject the
baggageheader.
Reproduction Code
Minimal Spock test against grpc-1.5. The same shape against an Armeria GrpcService fails the same way.
class GrpcServerBaggageTest extends InstrumentationSpecification {
def "inbound baggage is current in unary handler"() {
setup:
Map<String, String> seen = null
def greeter = new GreeterGrpc.GreeterImplBase() {
@Override
void sayHello(Helloworld.Request req, StreamObserver<Helloworld.Response> obs) {
seen = Baggage.fromContext(Context.current())?.asMap()
obs.onNext(Helloworld.Response.newBuilder().setMessage("hi").build())
obs.onCompleted()
}
}
def name = InProcessServerBuilder.generateName()
def server = InProcessServerBuilder.forName(name).addService(greeter).directExecutor().build().start()
def md = new Metadata()
md.put(Metadata.Key.of("baggage", Metadata.ASCII_STRING_MARSHALLER), "user.id=abc123")
def channel = InProcessChannelBuilder.forName(name)
.intercept(MetadataUtils.newAttachHeadersInterceptor(md)).directExecutor().build()
when:
GreeterGrpc.newBlockingStub(channel).sayHello(Helloworld.Request.newBuilder().setName("x").build())
then:
seen == ["user.id": "abc123"] // on master: seen == null (a span is current, baggage is not)
cleanup:
channel.shutdownNow(); server.shutdownNow()
}
}
- Vorherrschende Sprache
- Java
- Sterne
- 737
- Forks
- 361
- Ø Merge
- 3 T. 18 Std.
- Gemergte PRs (30 T.)
- 180
Entwicklungsumgebung
Erste Schritte
- Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
- Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
- Forken Sie das Repository und arbeiten Sie in einem Branch.
- Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.
Mehr aus DataDog/dd-trace-java
-
type: feature request
Schwierigkeit 1/5 1-3 Stunden Anfängerfreundlichkeit 70/100
DataDog/dd-trace-java#10245 · 1 Kommentar ·
Maintainer antworten meist innerhalb von 2 Tagen
-
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 62/100
DataDog/dd-trace-java#12608 ·
Maintainer antworten meist innerhalb von 2 Tagen
-
type: bug report
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 35/100
DataDog/dd-trace-java#12597 ·
Maintainer antworten meist innerhalb von 2 Tagen
-
Queueing-time profiler aborts the whole instrumentation install under a JDK 24+ AOT cache (zero spans); disabling that one feature is enoughEvtl. vergeben @mcculls hat das vor 8 Tagen übernommen. Offen
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 35/100
DataDog/dd-trace-java#12540 · 5 Kommentare · 1 zugewiesene Person ·
Maintainer antworten meist innerhalb von 2 Tagen
-
Schwierigkeit 3/5 1-2 Tage Anfängerfreundlichkeit 25/100
DataDog/dd-trace-java#12480 ·
Maintainer antworten meist innerhalb von 2 Tagen
Alle Issues in DataDog/dd-trace-java
Ähnliche Issues
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 78/100
Maintainer antworten meist innerhalb von 1 Tag
-
Content
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 68/100
RunestoneInteractive/rs#1559 · 1 Kommentar ·
Maintainer antworten meist innerhalb von 2 Tagen
-
documentation
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 86/100
inu-appcenter/memorIN-backend#298 ·
Maintainer antworten meist innerhalb von 1 Tag
-
bug
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 85/100
opendataloader-project/opendataloader-pdf#757 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 78/100
redhat-developer/intellij-quarkus#1626 ·