rebase + review feedback

open-telemetry · Sep 12, 2024 · c04c5bd · c04c5bd
1 parent 57f9d56
commit c04c5bd
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 7 deletions.
diff --git a/receiver/otelarrowreceiver/factory.go b/receiver/otelarrowreceiver/factory.go
@@ -20,7 +20,7 @@ const (
 	defaultGRPCEndpoint = "0.0.0.0:4317"
 
 	defaultMemoryLimitMiB  = 128
-	defaultRequestLimitMiB = defaultMemoryLimitMiB / 2
+	defaultRequestLimitMiB = 128
 	defaultWaiterLimit     = 1000
 )
 

diff --git a/receiver/otelarrowreceiver/internal/logs/otlp.go b/receiver/otelarrowreceiver/internal/logs/otlp.go
@@ -54,8 +54,7 @@ func (r *Receiver) Export(ctx context.Context, req plogotlp.ExportRequest) (plog
 		return plogotlp.NewExportResponse(), err
 	}
 	defer func() {
-		releaseErr := r.boundedQueue.Release(sizeBytes)
-		if releaseErr != nil {
+		if releaseErr := r.boundedQueue.Release(sizeBytes); releaseErr != nil {
 			r.logger.Error("Error releasing bytes from semaphore", zap.Error(releaseErr))
 		}
 	}()

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

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