Skip to content

Commit 6d5b131

Browse files
committed
update queue length
1 parent 3f01d90 commit 6d5b131

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

internal/trace/span_processor.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,8 @@ import (
2525

2626
// Defaults for batchQueueManagerOptions.
2727
const (
28-
DefaultMaxQueueLength = 2048
28+
DefaultMaxQueueLength = 1024
29+
DefaultMaxRetryQueueLength = 512
2930
DefaultMaxExportBatchLength = 100
3031
DefaultMaxExportBatchByteSize = 4 * 1024 * 1024 // 4MB
3132
MaxRetryExportBatchLength = 50
@@ -114,7 +115,7 @@ func NewBatchSpanProcessor(
114115
batchQueueManagerOptions{
115116
queueName: queueNameSpanRetry,
116117
batchTimeout: time.Duration(DefaultScheduleDelay) * time.Millisecond,
117-
maxQueueLength: DefaultMaxQueueLength,
118+
maxQueueLength: DefaultMaxRetryQueueLength,
118119
maxExportBatchLength: MaxRetryExportBatchLength,
119120
maxExportBatchByteSize: DefaultMaxExportBatchByteSize,
120121
exportFunc: newExportSpansFunc(exporter, nil, fileQM, finishEventProcessor),

0 commit comments

Comments
 (0)