Implemented sized channel with size -1

open-telemetry · Jan 13, 2025 · d73a4fc · d73a4fc
1 parent b92dff6
commit d73a4fc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/exporter/exporterhelper/internal/base_exporter.go b/exporter/exporterhelper/internal/base_exporter.go
@@ -103,7 +103,7 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe
 
 	if usePullingBasedExporterQueueBatcher.IsEnabled() && be.BatcherCfg.Enabled && !be.queueCfg.Enabled {
 		be.queueFactory = exporterqueue.NewBlockingMemoryQueueFactory[internal.Request]()
-		be.queueCfg.QueueSize = 20
+		be.queueCfg.QueueSize = -1
 		q := be.queueFactory(
 			context.Background(),
 			exporterqueue.Settings{