add nil check

open-telemetry · Sep 10, 2024 · 2877c04 · 2877c04
1 parent dc4ce95
commit 2877c04
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/receiver/otelarrowreceiver/internal/logs/otlp.go b/receiver/otelarrowreceiver/internal/logs/otlp.go
@@ -55,7 +55,9 @@ func (r *Receiver) Export(ctx context.Context, req plogotlp.ExportRequest) (plog
 	}
 	defer func() {
 		releaseErr := r.boundedQueue.Release(sizeBytes)
-		r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
+		if releaseErr != nil {
+			r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
+		}
 	}()
 
 	err = r.nextConsumer.ConsumeLogs(ctx, ld)

diff --git a/receiver/otelarrowreceiver/internal/metrics/otlp.go b/receiver/otelarrowreceiver/internal/metrics/otlp.go
@@ -55,7 +55,9 @@ func (r *Receiver) Export(ctx context.Context, req pmetricotlp.ExportRequest) (p
 	}
 	defer func() {
 		releaseErr := r.boundedQueue.Release(sizeBytes)
-		r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
+		if releaseErr != nil {
+			r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
+		}
 	}()
 
 	err = r.nextConsumer.ConsumeMetrics(ctx, md)

diff --git a/receiver/otelarrowreceiver/internal/trace/otlp.go b/receiver/otelarrowreceiver/internal/trace/otlp.go
@@ -55,7 +55,9 @@ func (r *Receiver) Export(ctx context.Context, req ptraceotlp.ExportRequest) (pt
 	}
 	defer func() {
 		releaseErr := r.boundedQueue.Release(sizeBytes)
-		r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
+		if releaseErr != nil {
+			r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
+		}
 	}()
 
 	err = r.nextConsumer.ConsumeTraces(ctx, td)