This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new a6932b60e91 [OpenTelemetry] Add traceparent and tracestate to extended
element metadata proto (#36963)
a6932b60e91 is described below
commit a6932b60e91469203acba78818ee68a05b70ca08
Author: Radosław Stankiewicz <[email protected]>
AuthorDate: Fri Dec 5 20:09:57 2025 +0100
[OpenTelemetry] Add traceparent and tracestate to extended element metadata
proto (#36963)
---
.../org/apache/beam/model/fn_execution/v1/beam_fn_api.proto | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git
a/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
b/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
index 4d907f2ac72..22b19ef0328 100644
---
a/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
+++
b/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
@@ -761,6 +761,15 @@ message Elements {
// extensible and backward compatible
message ElementMetadata {
optional DrainMode.Enum drain = 1;
+ // (Optional) As part of https://www.w3.org/TR/trace-context/ we are
forwarding a trace and participating in it.
+ // Traceparent header represents the incoming request in a tracing system
in a common format.
+ // Example value: 00-0af7651916cd43dd8448eb211c80319c-b7ad6b7169203331-01
+ optional string traceparent = 2;
+ // (Optional) tracestate extends traceparent with open telemetry data
represented by a set of name/value pairs.
+ // Format specified https://www.w3.org/TR/trace-context/#list for
interoperability and commonly used
+ // across IOs - Kafka, PubSub, http.
+ // Example value: congo=t61rcWkgMzE
+ optional string tracestate = 3;
}
// Represent the encoded user timer for a given instruction, transform and
