diff --git a/apis/fluentd/v1alpha1/plugins/common/buffer_types.go b/apis/fluentd/v1alpha1/plugins/common/buffer_types.go index 8b4f59338..65cc9a324 100644 --- a/apis/fluentd/v1alpha1/plugins/common/buffer_types.go +++ b/apis/fluentd/v1alpha1/plugins/common/buffer_types.go @@ -210,7 +210,7 @@ func (b *Buffer) Params(_ plugins.SecretLoader) (*params.PluginStore, error) { } if b.TotalLimitSize != nil { - ps.InsertPairs("chunk_limit_size", *b.TotalLimitSize) + ps.InsertPairs("total_limit_size", *b.TotalLimitSize) } if b.QueueLimitLength != nil { @@ -254,7 +254,7 @@ func (b *Buffer) Params(_ plugins.SecretLoader) (*params.PluginStore, error) { } if b.RetrySecondaryThreshold != nil { - ps.InsertPairs("retry_secondary_threshold", fmt.Sprint(*b.RetryTimeout)) + ps.InsertPairs("retry_secondary_threshold", fmt.Sprint(*b.RetrySecondaryThreshold)) } if b.RetryType != nil { diff --git a/apis/fluentd/v1alpha1/tests/expected/duplicate-removal-cr-specs.cfg b/apis/fluentd/v1alpha1/tests/expected/duplicate-removal-cr-specs.cfg index 16a9a1552..967686492 100644 --- a/apis/fluentd/v1alpha1/tests/expected/duplicate-removal-cr-specs.cfg +++ b/apis/fluentd/v1alpha1/tests/expected/duplicate-removal-cr-specs.cfg @@ -79,8 +79,8 @@ @id common_buffer @type file - chunk_limit_size 5GB path /buffers/fd.log + total_limit_size 5GB host host @@ -98,8 +98,8 @@ @id common_buffer @type file - chunk_limit_size 5GB path /buffers/fd.log + total_limit_size 5GB @type json @@ -116,8 +116,8 @@ @id common_buffer @type file - chunk_limit_size 5GB path /buffers/fd.log + total_limit_size 5GB @@ -172,8 +172,8 @@ @id common_buffer @type file - chunk_limit_size 5GB path /buffers/fd.log + total_limit_size 5GB host host @@ -191,8 +191,8 @@ @id common_buffer @type file - chunk_limit_size 5GB path /buffers/fd.log + total_limit_size 5GB @type json @@ -209,8 +209,8 @@ @id common_buffer @type file - chunk_limit_size 5GB path /buffers/fd.log + total_limit_size 5GB \ No newline at end of file