Skip to content

Commit 3729a81

Browse files
committed
Add freeze to temporal string key
1 parent fa429eb commit 3729a81

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

lib/fluent/plugin/filter_concat.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ def filter_stream(tag, es)
130130
end
131131
end
132132
if @mode == :partial_metadata
133-
unless record.key?("partial_message")
133+
unless record.key?("partial_message".freeze)
134134
new_es.add(time, record)
135135
next
136136
end
@@ -146,10 +146,10 @@ def filter_stream(tag, es)
146146
merged_record.delete(@partial_key) unless @keep_partial_key
147147
when :partial_metadata
148148
unless @keep_partial_metadata
149-
merged_record.delete("partial_message")
150-
merged_record.delete("partial_id")
151-
merged_record.delete("partial_ordinal")
152-
merged_record.delete("partial_last")
149+
merged_record.delete("partial_message".freeze)
150+
merged_record.delete("partial_id".freeze)
151+
merged_record.delete("partial_ordinal".freeze)
152+
merged_record.delete("partial_last".freeze)
153153
end
154154
end
155155
new_es.add(time, merged_record)

0 commit comments

Comments
 (0)