From cf3b539986bf039fbfaae66fb96c31b67bbb3182 Mon Sep 17 00:00:00 2001 From: juicer Date: Sun, 22 Oct 2023 11:33:33 -0700 Subject: [PATCH] fix autoTypeCast & renewRecord Signed-off-by: juicer --- apis/fluentd/v1alpha1/plugins/filter/types.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/apis/fluentd/v1alpha1/plugins/filter/types.go b/apis/fluentd/v1alpha1/plugins/filter/types.go index 60547ff89..8ace91766 100644 --- a/apis/fluentd/v1alpha1/plugins/filter/types.go +++ b/apis/fluentd/v1alpha1/plugins/filter/types.go @@ -164,7 +164,10 @@ func (f *Filter) recordTransformerPlugin(parent *params.PluginStore, loader plug parent.InsertPairs("enable_ruby", fmt.Sprint(*f.RecordTransformer.EnableRuby)) } if f.RecordTransformer.AutoTypeCast != nil { - parent.InsertPairs("renew_record", fmt.Sprint(*f.RecordTransformer.AutoTypeCast)) + parent.InsertPairs("auto_typecast", fmt.Sprint(*f.RecordTransformer.AutoTypeCast)) + } + if f.RecordTransformer.RenewRecord != nil { + parent.InsertPairs("renew_record", fmt.Sprint(*f.RecordTransformer.RenewRecord)) } if f.RecordTransformer.RenewTimeKey != nil { parent.InsertPairs("renew_time_key", fmt.Sprint(*f.RecordTransformer.RenewTimeKey))