Skip to content

Commit fa429eb

Browse files
committed
Move tag check into top. tag doesn't depend on event stream
1 parent 3e7b94a commit fa429eb

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

lib/fluent/plugin/filter_concat.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -113,12 +113,12 @@ def shutdown
113113
end
114114

115115
def filter_stream(tag, es)
116+
if /\Afluent\.(?:trace|debug|info|warn|error|fatal)\z/ =~ tag
117+
return es
118+
end
119+
116120
new_es = Fluent::MultiEventStream.new
117121
es.each do |time, record|
118-
if /\Afluent\.(?:trace|debug|info|warn|error|fatal)\z/ =~ tag
119-
new_es.add(time, record)
120-
next
121-
end
122122
unless record.key?(@key)
123123
new_es.add(time, record)
124124
next

0 commit comments

Comments
 (0)