[pkg/translator/jaeger] migrate semantic convention from v1.25.0 to v1.40.0 (#49301)

Fixes #45036

`http.response.status_code` is the replacement atttribute for
`http.status_code`
Here is the reference link:
https://opentelemetry.io/docs/specs/semconv/registry/attributes/http/#http-status-code

#### Authorship

- [x] I, a human, wrote this pull request description myself.

---------

Signed-off-by: singhvibhanshu <find.vibhanshu@gmail.com>

Author: singhvibhanshu

.chloggen/config.yaml

@@ -159,6 +159,7 @@ components:
     - pkg/faro
     - pkg/fileconsumer
     - pkg/golden
+    - pkg/jaeger
     - pkg/kafka/configkafka
     - pkg/otelarrow
     - pkg/ottl
@@ -173,7 +174,6 @@ components:
     - pkg/status
     - pkg/topic
     - pkg/translator/azure
-    - pkg/translator/jaeger
     - pkg/translator/loki
     - pkg/translator/pprof
     - pkg/translator/prometheusremotewrite

.chloggen/migrateHTTP-45036.yaml

@@ -0,0 +1,35 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. receiver/filelog)
+component: pkg/jaeger
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Migrate http.status_code (v1.25.0) semantic convention to http.response.status_code (v1.40.0)
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [45036]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext: |
+  The migration is gated behind two alpha (disabled by default) feature gates:
+  enable `pkg.translator.jaeger.EmitV1HttpConventions` to emit `http.response.status_code`, and
+  additionally enable `pkg.translator.jaeger.DontEmitV0HttpConventions` to stop emitting the
+  deprecated `http.status_code`.
+  Both gates will graduate to beta (enabled by default) and eventually be removed, after which the
+  translator will only emit `http.response.status_code`. That removal is a breaking change for
+  anything still relying on `http.status_code`, so please migrate your dashboards, alerts and
+  queries now.
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: []

pkg/translator/jaeger/documentation.md

@@ -0,0 +1,14 @@
+[comment]: <> (Code generated by mdatagen. DO NOT EDIT.)
+
+# jaeger
+
+## Feature Gates
+
+This component has the following feature gates:
+
+| Feature Gate | Stage | Description | From Version | To Version | Reference |
+| ------------ | ----- | ----------- | ------------ | ---------- | --------- |
+| `pkg.translator.jaeger.DontEmitV0HttpConventions` | alpha | When enabled, the Jaeger translator no longer emits the deprecated http.status_code attribute (semconv v1.25.0). Requires pkg.translator.jaeger.EmitV1HttpConventions to also be enabled. | v0.158.0 | N/A | [Link](https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/45036) |
+| `pkg.translator.jaeger.EmitV1HttpConventions` | alpha | When enabled, the Jaeger translator emits http.response.status_code (semconv v1.40.0) instead of the deprecated http.status_code (semconv v1.25.0). | v0.158.0 | N/A | [Link](https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/45036) |
+
+For more information about feature gates, see the [Feature Gates](https://github.com/open-telemetry/opentelemetry-collector/blob/main/featuregate/README.md) documentation.

pkg/translator/jaeger/package_test.go …nslator/jaeger/generated_package_test.gopkg/translator/jaeger/package_test.go renamed to pkg/translator/jaeger/generated_package_test.go pkg/translator/jaeger/package_test.go renamed to pkg/translator/jaeger/generated_package_test.go

@@ -9,6 +9,7 @@ require (
 	github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal v0.157.0
 	github.com/open-telemetry/opentelemetry-collector-contrib/pkg/core/xidutils v0.157.0
 	github.com/stretchr/testify v1.11.1
+	go.opentelemetry.io/collector/featuregate v1.63.1-0.20260723141305-52e6bf4aaaba
 	go.opentelemetry.io/collector/pdata v1.63.1-0.20260723141305-52e6bf4aaaba
 	go.opentelemetry.io/otel v1.44.0
 	go.uber.org/goleak v1.3.0
@@ -26,7 +27,6 @@ require (
 	github.com/modern-go/reflect2 v1.0.3-0.20250322232337-35a7c28c31ee // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/rogpeppe/go-internal v1.10.0 // indirect
-	go.opentelemetry.io/collector/featuregate v1.63.1-0.20260723141305-52e6bf4aaaba // indirect
 	go.opentelemetry.io/collector/pdata/pprofile v0.157.1-0.20260723141305-52e6bf4aaaba // indirect
 	go.uber.org/multierr v1.11.0 // indirect
 	golang.org/x/net v0.55.0 // indirect

pkg/translator/jaeger/go.mod

@@ -20,6 +20,7 @@ import (
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/occonventions"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/tracetranslator"
 	idutils "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/core/xidutils"
+	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/jaeger/internal/metadata"
 )
 
 var blankJaegerProtoSpan = new(model.Span)
@@ -234,19 +235,32 @@ func jSpanToInternal(span *model.Span, dest ptrace.Span) {
 
 func jTagsToInternalAttributes(tags []model.KeyValue, dest pcommon.Map) {
 	for _, tag := range tags {
-		switch tag.GetVType() {
-		case model.ValueType_STRING:
-			dest.PutStr(tag.Key, tag.GetVStr())
-		case model.ValueType_BOOL:
-			dest.PutBool(tag.Key, tag.GetVBool())
-		case model.ValueType_INT64:
-			dest.PutInt(tag.Key, tag.GetVInt64())
-		case model.ValueType_FLOAT64:
-			dest.PutDouble(tag.Key, tag.GetVFloat64())
-		case model.ValueType_BINARY:
-			dest.PutEmptyBytes(tag.Key).FromRaw(tag.GetVBinary())
-		default:
-			dest.PutStr(tag.Key, fmt.Sprintf("<Unknown Jaeger TagType %q>", tag.GetVType()))
+		keys := []string{tag.Key}
+		if tag.Key == string(conventionsv125.HTTPStatusCodeKey) || tag.Key == string(conventions.HTTPResponseStatusCodeKey) {
+			keys = nil
+			if !metadata.PkgTranslatorJaegerDontEmitV0HTTPConventionsFeatureGate.IsEnabled() {
+				keys = append(keys, string(conventionsv125.HTTPStatusCodeKey))
+			}
+			if metadata.PkgTranslatorJaegerEmitV1HTTPConventionsFeatureGate.IsEnabled() {
+				keys = append(keys, string(conventions.HTTPResponseStatusCodeKey))
+			}
+		}
+
+		for _, key := range keys {
+			switch tag.GetVType() {
+			case model.ValueType_STRING:
+				dest.PutStr(key, tag.GetVStr())
+			case model.ValueType_BOOL:
+				dest.PutBool(key, tag.GetVBool())
+			case model.ValueType_INT64:
+				dest.PutInt(key, tag.GetVInt64())
+			case model.ValueType_FLOAT64:
+				dest.PutDouble(key, tag.GetVFloat64())
+			case model.ValueType_BINARY:
+				dest.PutEmptyBytes(key).FromRaw(tag.GetVBinary())
+			default:
+				dest.PutStr(key, fmt.Sprintf("<Unknown Jaeger TagType %q>", tag.GetVType()))
+			}
 		}
 	}
 }
@@ -292,7 +306,7 @@ func setInternalSpanStatus(attrs pcommon.Map, span ptrace.Span) {
 		// otel.status_message tag will have already been removed if
 		// statusExists is true.
 		attrs.Remove(string(conventions.OTelStatusCodeKey))
-	} else if httpCodeAttr, ok := attrs.Get(string(conventionsv125.HTTPStatusCodeKey)); !statusExists && ok {
+	} else if httpCodeAttr, ok := getHTTPStatusCodeAttr(attrs); !statusExists && ok {
 		// Fallback to introspecting if this span represents a failed HTTP
 		// request or response, but again, only do so if the `error` tag was
 		// not set to true and no explicit status was sent.
@@ -347,6 +361,18 @@ func codeFromAttr(attrVal pcommon.Value) (int64, error) {
 	return val, nil
 }
 
+// getHTTPStatusCodeAttr returns the HTTP status code attribute value, checking
+// both the deprecated http.status_code (semconv v1.25.0) and the current
+// http.response.status_code (semconv v1.40.0) keys. This ensures span status is
+// still derived from the HTTP status code regardless of which HTTP semantic
+// conventions the Jaeger translator is configured to emit.
+func getHTTPStatusCodeAttr(attrs pcommon.Map) (pcommon.Value, bool) {
+	if attr, ok := attrs.Get(string(conventionsv125.HTTPStatusCodeKey)); ok {
+		return attr, true
+	}
+	return attrs.Get(string(conventions.HTTPResponseStatusCodeKey))
+}
+
 func getStatusCodeFromHTTPStatusAttr(attrVal pcommon.Value, kind ptrace.SpanKind) (ptrace.StatusCode, error) {
 	statusCode, err := codeFromAttr(attrVal)
 	if err != nil {

pkg/translator/jaeger/internal/metadata/generated_feature_gates.go

@@ -13,6 +13,7 @@ import (
 	"github.com/jaegertracing/jaeger-idl/model/v1"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"go.opentelemetry.io/collector/featuregate"
 	"go.opentelemetry.io/collector/pdata/pcommon"
 	"go.opentelemetry.io/collector/pdata/ptrace"
 
@@ -446,6 +447,14 @@ func TestSetInternalSpanStatus(t *testing.T) {
 			status:           errorStatus,
 			attrsModifiedLen: 1,
 		},
+		{
+			name: "http.response.status_code tag is set as string (v1 conventions)",
+			attrs: map[string]any{
+				"http.response.status_code": "404",
+			},
+			status:           errorStatus,
+			attrsModifiedLen: 1,
+		},
 		{
 			name: "http.status_code, http.status_message and error tags are set",
 			attrs: map[string]any{
@@ -1093,3 +1102,39 @@ func generateTracesTwoSpansFromTwoLibraries() ptrace.Traces {
 
 	return td
 }
+
+func TestJTagsToInternalAttributesHTTPConventionsMigration(t *testing.T) {
+	cases := []struct {
+		name       string
+		emitV1     bool
+		dontEmitV0 bool
+		expectsV0  bool
+		expectsV1  bool
+	}{
+		{name: "v0 only", emitV1: false, dontEmitV0: false, expectsV0: true, expectsV1: false},
+		{name: "double publish", emitV1: true, dontEmitV0: false, expectsV0: true, expectsV1: true},
+		{name: "v1 only", emitV1: true, dontEmitV0: true, expectsV0: false, expectsV1: true},
+	}
+
+	for _, tc := range cases {
+		t.Run(tc.name, func(t *testing.T) {
+			err := featuregate.GlobalRegistry().Set("pkg.translator.jaeger.EmitV1HttpConventions", tc.emitV1)
+			assert.NoError(t, err)
+			err = featuregate.GlobalRegistry().Set("pkg.translator.jaeger.DontEmitV0HttpConventions", tc.dontEmitV0)
+			assert.NoError(t, err)
+			t.Cleanup(func() {
+				assert.NoError(t, featuregate.GlobalRegistry().Set("pkg.translator.jaeger.DontEmitV0HttpConventions", false))
+				assert.NoError(t, featuregate.GlobalRegistry().Set("pkg.translator.jaeger.EmitV1HttpConventions", false))
+			})
+
+			tags := []model.KeyValue{{Key: "http.status_code", VType: model.ValueType_STRING, VStr: "500"}}
+			dest := pcommon.NewMap()
+			jTagsToInternalAttributes(tags, dest)
+
+			_, hasV0 := dest.Get("http.status_code")
+			_, hasV1 := dest.Get("http.response.status_code")
+			assert.Equal(t, tc.expectsV0, hasV0)
+			assert.Equal(t, tc.expectsV1, hasV1)
+		})
+	}
+}

pkg/translator/jaeger/jaegerproto_to_traces.go

@@ -11,10 +11,12 @@ import (
 	"github.com/jaegertracing/jaeger-idl/thrift-gen/jaeger"
 	"go.opentelemetry.io/collector/pdata/pcommon"
 	"go.opentelemetry.io/collector/pdata/ptrace"
+	conventionsv125 "go.opentelemetry.io/otel/semconv/v1.25.0"
 	conventions "go.opentelemetry.io/otel/semconv/v1.40.0"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/tracetranslator"
 	idutils "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/core/xidutils"
+	"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/jaeger/internal/metadata"
 )
 
 var blankJaegerThriftSpan = new(jaeger.Span)
@@ -144,19 +146,32 @@ func jThriftSpanToInternal(span *jaeger.Span, dest ptrace.Span) {
 // jThriftTagsToInternalAttributes sets internal span links based on jaeger span references skipping excludeParentID
 func jThriftTagsToInternalAttributes(tags []*jaeger.Tag, dest pcommon.Map) {
 	for _, tag := range tags {
-		switch tag.GetVType() {
-		case jaeger.TagType_STRING:
-			dest.PutStr(tag.Key, tag.GetVStr())
-		case jaeger.TagType_BOOL:
-			dest.PutBool(tag.Key, tag.GetVBool())
-		case jaeger.TagType_LONG:
-			dest.PutInt(tag.Key, tag.GetVLong())
-		case jaeger.TagType_DOUBLE:
-			dest.PutDouble(tag.Key, tag.GetVDouble())
-		case jaeger.TagType_BINARY:
-			dest.PutEmptyBytes(tag.Key).FromRaw(tag.GetVBinary())
-		default:
-			dest.PutStr(tag.Key, fmt.Sprintf("<Unknown Jaeger TagType %q>", tag.GetVType()))
+		keys := []string{tag.Key}
+		if tag.Key == string(conventionsv125.HTTPStatusCodeKey) || tag.Key == string(conventions.HTTPResponseStatusCodeKey) {
+			keys = nil
+			if !metadata.PkgTranslatorJaegerDontEmitV0HTTPConventionsFeatureGate.IsEnabled() {
+				keys = append(keys, string(conventionsv125.HTTPStatusCodeKey))
+			}
+			if metadata.PkgTranslatorJaegerEmitV1HTTPConventionsFeatureGate.IsEnabled() {
+				keys = append(keys, string(conventions.HTTPResponseStatusCodeKey))
+			}
+		}
+
+		for _, key := range keys {
+			switch tag.GetVType() {
+			case jaeger.TagType_STRING:
+				dest.PutStr(key, tag.GetVStr())
+			case jaeger.TagType_BOOL:
+				dest.PutBool(key, tag.GetVBool())
+			case jaeger.TagType_LONG:
+				dest.PutInt(key, tag.GetVLong())
+			case jaeger.TagType_DOUBLE:
+				dest.PutDouble(key, tag.GetVDouble())
+			case jaeger.TagType_BINARY:
+				dest.PutEmptyBytes(key).FromRaw(tag.GetVBinary())
+			default:
+				dest.PutStr(key, fmt.Sprintf("<Unknown Jaeger TagType %q>", tag.GetVType()))
+			}
 		}
 	}
 }

pkg/translator/jaeger/jaegerproto_to_traces_test.go

@@ -10,6 +10,7 @@ import (
 	"github.com/jaegertracing/jaeger-idl/thrift-gen/jaeger"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"go.opentelemetry.io/collector/featuregate"
 	"go.opentelemetry.io/collector/pdata/pcommon"
 	"go.opentelemetry.io/collector/pdata/ptrace"
 
@@ -343,3 +344,41 @@ func BenchmarkThriftBatchToInternalTraces(b *testing.B) {
 		assert.NoError(b, err)
 	}
 }
+
+func TestJThriftTagsToInternalAttributesHTTPConventionsMigration(t *testing.T) {
+	cases := []struct {
+		name       string
+		emitV1     bool
+		dontEmitV0 bool
+		expectsV0  bool
+		expectsV1  bool
+	}{
+		{name: "v0 only", emitV1: false, dontEmitV0: false, expectsV0: true, expectsV1: false},
+		{name: "double publish", emitV1: true, dontEmitV0: false, expectsV0: true, expectsV1: true},
+		{name: "v1 only", emitV1: true, dontEmitV0: true, expectsV0: false, expectsV1: true},
+	}
+
+	for _, tc := range cases {
+		t.Run(tc.name, func(t *testing.T) {
+			err := featuregate.GlobalRegistry().Set("pkg.translator.jaeger.EmitV1HttpConventions", tc.emitV1)
+			assert.NoError(t, err)
+			err = featuregate.GlobalRegistry().Set("pkg.translator.jaeger.DontEmitV0HttpConventions", tc.dontEmitV0)
+			assert.NoError(t, err)
+			t.Cleanup(func() {
+				assert.NoError(t, featuregate.GlobalRegistry().Set("pkg.translator.jaeger.DontEmitV0HttpConventions", false))
+				assert.NoError(t, featuregate.GlobalRegistry().Set("pkg.translator.jaeger.EmitV1HttpConventions", false))
+			})
+
+			key := "http.status_code"
+			val := "500"
+			tags := []*jaeger.Tag{{Key: key, VType: jaeger.TagType_STRING, VStr: &val}}
+			dest := pcommon.NewMap()
+			jThriftTagsToInternalAttributes(tags, dest)
+
+			_, hasV0 := dest.Get("http.status_code")
+			_, hasV1 := dest.Get("http.response.status_code")
+			assert.Equal(t, tc.expectsV0, hasV0)
+			assert.Equal(t, tc.expectsV1, hasV1)
+		})
+	}
+}