diff --git a/exporter/awskinesisexporter/internal/batch/encode_marshaler.go b/exporter/awskinesisexporter/internal/batch/encode_marshaler.go index 5473610d5ce2..d1b9648b18cb 100644 --- a/exporter/awskinesisexporter/internal/batch/encode_marshaler.go +++ b/exporter/awskinesisexporter/internal/batch/encode_marshaler.go @@ -57,12 +57,12 @@ func (bm *batchMarshaller) Logs(ld plog.Logs) (*Batch, error) { if errors.Is(err, ErrUnsupportedEncoding) { return nil, err } - errs = multierr.Append(errs, consumererror.NewLogs(err, export.Clone())) + errs = multierr.Append(errs, consumererror.NewLogs(err, export)) continue } if err := bt.AddRecord(data, bm.partitioner(export)); err != nil { - errs = multierr.Append(errs, consumererror.NewLogs(err, export.Clone())) + errs = multierr.Append(errs, consumererror.NewLogs(err, export)) } } @@ -89,12 +89,12 @@ func (bm *batchMarshaller) Traces(td ptrace.Traces) (*Batch, error) { if errors.Is(err, ErrUnsupportedEncoding) { return nil, err } - errs = multierr.Append(errs, consumererror.NewTraces(err, export.Clone())) + errs = multierr.Append(errs, consumererror.NewTraces(err, export)) continue } if err := bt.AddRecord(data, bm.partitioner(span)); err != nil { - errs = multierr.Append(errs, consumererror.NewTraces(err, export.Clone())) + errs = multierr.Append(errs, consumererror.NewTraces(err, export)) } } @@ -121,12 +121,12 @@ func (bm *batchMarshaller) Metrics(md pmetric.Metrics) (*Batch, error) { if errors.Is(err, ErrUnsupportedEncoding) { return nil, err } - errs = multierr.Append(errs, consumererror.NewMetrics(err, export.Clone())) + errs = multierr.Append(errs, consumererror.NewMetrics(err, export)) continue } if err := bt.AddRecord(data, bm.partitioner(export)); err != nil { - errs = multierr.Append(errs, consumererror.NewMetrics(err, export.Clone())) + errs = multierr.Append(errs, consumererror.NewMetrics(err, export)) } } diff --git a/pkg/resourcetotelemetry/resource_to_telemetry.go b/pkg/resourcetotelemetry/resource_to_telemetry.go index b5bfa85b4281..d36b425b0ed8 100644 --- a/pkg/resourcetotelemetry/resource_to_telemetry.go +++ b/pkg/resourcetotelemetry/resource_to_telemetry.go @@ -58,7 +58,8 @@ func WrapMetricsExporter(set Settings, exporter component.MetricsExporter) compo } func convertToMetricsAttributes(md pmetric.Metrics) pmetric.Metrics { - cloneMd := md.Clone() + cloneMd := pmetric.NewMetrics() + md.CopyTo(cloneMd) rms := cloneMd.ResourceMetrics() for i := 0; i < rms.Len(); i++ { resource := rms.At(i).Resource()