From 64debea40377b7b387fd9e2fa6a6c28feb04ad62 Mon Sep 17 00:00:00 2001 From: Ahrav Dutta Date: Thu, 18 Jan 2024 06:33:59 -0800 Subject: [PATCH] set default limit to 10MB --- pkg/writers/buffered_file_writer/bufferedfilewriter.go | 2 +- pkg/writers/buffered_file_writer/bufferedfilewriter_test.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/writers/buffered_file_writer/bufferedfilewriter.go b/pkg/writers/buffered_file_writer/bufferedfilewriter.go index 292af333b6f0..e5458d26b23b 100644 --- a/pkg/writers/buffered_file_writer/bufferedfilewriter.go +++ b/pkg/writers/buffered_file_writer/bufferedfilewriter.go @@ -26,7 +26,7 @@ func WithThreshold(threshold uint64) Option { // New creates a new BufferedFileWriter with the given options. func New(opts ...Option) *BufferedFileWriter { - const defaultThreshold = 20 * 1024 * 1024 // 20MB + const defaultThreshold = 10 * 1024 * 1024 // 10MB w := &BufferedFileWriter{threshold: defaultThreshold} for _, opt := range opts { opt(w) diff --git a/pkg/writers/buffered_file_writer/bufferedfilewriter_test.go b/pkg/writers/buffered_file_writer/bufferedfilewriter_test.go index 45263b08d82f..95a2190946c1 100644 --- a/pkg/writers/buffered_file_writer/bufferedfilewriter_test.go +++ b/pkg/writers/buffered_file_writer/bufferedfilewriter_test.go @@ -14,8 +14,8 @@ func TestBufferedFileWriterNewThreshold(t *testing.T) { t.Parallel() const ( - defaultThreshold = 20 * 1024 * 1024 // 20MB - customThreshold = 10 * 1024 * 1024 // 10MB + defaultThreshold = 10 * 1024 * 1024 // 10MB + customThreshold = 20 * 1024 * 1024 // 20MB ) tests := []struct {