wip

Signed-off-by: Benedikt Bongartz <[email protected]>

apis/v1beta1/collector_webhook.go

@@ -21,6 +21,7 @@ import (
 
 	"github.com/go-logr/logr"
 	autoscalingv2 "k8s.io/api/autoscaling/v2"
+	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/util/intstr"
 	"k8s.io/apimachinery/pkg/util/validation"
@@ -79,6 +80,10 @@ func (c CollectorWebhook) Default(_ context.Context, obj runtime.Object) error {
 		otelcol.Spec.TargetAllocator.Replicas = &one
 	}
 
+	if otelcol.Spec.TargetAllocator.Enabled {
+		TAUnifiyEnvVarExpansion(otelcol)
+	}
+
 	if otelcol.Spec.Autoscaler != nil && otelcol.Spec.Autoscaler.MaxReplicas != nil {
 		if otelcol.Spec.Autoscaler.MinReplicas == nil {
 			otelcol.Spec.Autoscaler.MinReplicas = otelcol.Spec.Replicas
@@ -449,3 +454,22 @@ func SetupCollectorWebhook(mgr ctrl.Manager, cfg config.Config, reviewer *rbac.R
 		WithDefaulter(cvw).
 		Complete()
 }
+
+// TAUnifiyEnvVarExpansion enables confmap.unifyEnvVarExpansion featuregate on collector instances associated to TA..
+// NOTE: We need this for now until 0.105.0 is out with this fix:
+// https://github.com/open-telemetry/opentelemetry-collector/commit/637b1f42fcb7cbb7ef8a50dcf41d0a089623a8b7
+func TAUnifiyEnvVarExpansion(otelcol *OpenTelemetryCollector) {
+	const (
+		baseFlag = "--feature-gates"
+		fgFlag   = "-confmap.unifyEnvVarExpansion"
+	)
+	if otelcol.Spec.Args == nil {
+		otelcol.Spec.Args = make(map[string]string)
+	}
+	args, ok := otelcol.Spec.Args[baseFlag]
+	if !ok || len(args) == 0 {
+		otelcol.Spec.Args[baseFlag] = fgFlag
+	} else {
+		otelcol.Spec.Args[baseFlag] += "," + fgFlag
+	}
+}

pkg/collector/upgrade/v0_104_0.go

@@ -21,6 +21,15 @@ import (
 	"github.com/open-telemetry/opentelemetry-operator/apis/v1beta1"
 )
 
+func upgrade0_104_0_TA(_ VersionUpgrade, otelcol *v1beta1.OpenTelemetryCollector) (*v1beta1.OpenTelemetryCollector, error) {
+	if !otelcol.Spec.TargetAllocator.Enabled {
+		return otelcol, nil
+	}
+
+	v1beta1.TAUnifiyEnvVarExpansion(otelcol)
+	return otelcol, nil
+}
+
 func upgrade0_104_0(u VersionUpgrade, otelcol *v1beta1.OpenTelemetryCollector) (*v1beta1.OpenTelemetryCollector, error) {
 	for key, rc := range otelcol.Spec.Config.Receivers.Object {
 		// check if otel is configured

pkg/collector/upgrade/v0_104_0_test.go

@@ -19,13 +19,13 @@ import (
 	_ "embed"
 	"testing"
 
+	"github.com/stretchr/testify/assert"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/tools/record"
 
 	"github.com/open-telemetry/opentelemetry-operator/apis/v1beta1"
 	"github.com/open-telemetry/opentelemetry-operator/internal/version"
 	"github.com/open-telemetry/opentelemetry-operator/pkg/collector/upgrade"
-	"github.com/stretchr/testify/assert"
 )
 
 func Test0_104_0Upgrade(t *testing.T) {

pkg/collector/upgrade/versions.go

@@ -94,6 +94,10 @@ var (
 			Version:        *semver.MustParse("0.104.0"),
 			upgradeV1beta1: upgrade0_104_0,
 		},
+		{
+			Version:        *semver.MustParse("0.104.0"),
+			upgradeV1beta1: upgrade0_104_0_TA,
+		},
 	}
 
 	// Latest represents the latest version that we need to upgrade. This is not necessarily the latest known version.