fix: incorrect field names in fluentd buffer plugin

fluent · Jul 6, 2023 · 1339796 · 1339796
1 parent ab72254
commit 1339796
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 {