updated config

Author: XuechunHou

exporter/exporterhelper/internal/queuebatch/batcher.go

@@ -36,12 +36,19 @@ func NewBatcher(cfg configoptional.Optional[BatchConfig], set batcherSettings[re
 	}
 	bCfg := cfg.Get()
 
-	// bCfg.Sizers is guaranteed to have exactly one entry due to Validate()
-	for szt, limit := range bCfg.Sizers {
-		bCfg.Sizer = szt
-		bCfg.MinSize = limit.MinSize
-		bCfg.MaxSize = limit.MaxSize
-		break
+	if len(bCfg.Sizers) > 0 {
+		// Normalize the first sizer to legacy fields (should only be one because of Validate)
+		for szt, limit := range bCfg.Sizers {
+			bCfg.Sizer = szt
+			bCfg.MinSize = limit.MinSize
+			bCfg.MaxSize = limit.MaxSize
+			break
+		}
+	} else {
+		// Fallback to default limits (items: 8192, 0)
+		bCfg.Sizer = request.SizerTypeItems
+		bCfg.MinSize = 8192
+		bCfg.MaxSize = 0
 	}
 
 	sizer := request.NewSizer(bCfg.Sizer)

exporter/exporterhelper/internal/queuebatch/config.go

@@ -152,9 +152,7 @@ func (cfg *BatchConfig) Validate() error {
 		return errors.New("`batch` does not support `min_size`, `max_size`, `sizer` fields anymore, please use `sizers` instead")
 	}
 
-	if len(cfg.Sizers) == 0 {
-		return errors.New("`sizers` cannot be empty; leave it unset to use default batch settings, or configure at least one sizer limit")
-	}
+
 
 	if len(cfg.Sizers) > 1 {
 		return errors.New("`sizers` supports only one entry at this moment")

exporter/exporterhelper/internal/queuebatch/config_test.go

@@ -46,7 +46,7 @@ func TestConfig_Validate(t *testing.T) {
 	cfg = newTestConfig()
 	cfg.Batch.Get().Sizers = map[request.SizerType]SizerLimit{}
 	cfg.Batch.Get().Sizer = request.SizerType{}
-	require.EqualError(t, xconfmap.Validate(cfg), "batch: `sizers` cannot be empty; leave it unset to use default batch settings, or configure at least one sizer limit")
+	require.NoError(t, xconfmap.Validate(cfg))
 
 	cfg = newTestConfig()
 	cfg.Sizer = request.SizerTypeBytes
@@ -131,11 +131,17 @@ func TestBatchConfig_Validate(t *testing.T) {
 	cfg.Sizers[request.SizerTypeBytes] = SizerLimit{MinSize: 100}
 	require.EqualError(t, xconfmap.Validate(cfg), "`sizers` supports only one entry at this moment")
 
-	// Empty Sizers -> error
+	// Empty Sizers -> no error (falls back to defaults)
+	cfg = BatchConfig{
+		FlushTimeout: 200 * time.Millisecond,
+	}
+	require.NoError(t, xconfmap.Validate(cfg))
+
 	cfg = BatchConfig{
 		FlushTimeout: 200 * time.Millisecond,
+		Sizers:       map[request.SizerType]SizerLimit{},
 	}
-	require.EqualError(t, xconfmap.Validate(cfg), "`sizers` cannot be empty; leave it unset to use default batch settings, or configure at least one sizer limit")
+	require.NoError(t, xconfmap.Validate(cfg))
 
 	// Programmatic legacy usage -> error
 	cfg = BatchConfig{
@@ -241,6 +247,21 @@ func TestUnmarshal(t *testing.T) {
 				return cfg
 			},
 		},
+		{
+			path: "batch_set_sizers_empty.yaml",
+			expectedCfg: func() configoptional.Optional[Config] {
+				cfg := newBaseCfg()
+				cfg.Get().Sizer = request.SizerTypeBytes
+				cfg.Get().QueueSize = 2000
+				cfg.Get().Batch = configoptional.Some(BatchConfig{
+					FlushTimeout: 2 * time.Second,
+					Sizers: map[request.SizerType]SizerLimit{
+						request.SizerTypeItems: {MinSize: 8192},
+					},
+				})
+				return cfg
+			},
+		},
 		{
 			path:        "batch_set_nonempty_no_explicit_sizer.yaml",
 			expectedErr: "`batch` does not support `min_size`, `max_size`, `sizer` fields anymore, please use `sizers` instead",

exporter/exporterhelper/internal/queuebatch/testdata/batch_set_sizers_empty.yaml

@@ -0,0 +1,6 @@
+enabled: true
+sizer: bytes
+queue_size: 2000
+batch:
+  flush_timeout: 2s
+  sizers: {}