use thread local unpacker

Signed-off-by: Yuta Iwama <[email protected]>
daipom · Aug 16, 2019 · b8021e9 · b8021e9
1 parent f4186cf
commit b8021e9
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/fluent/event_router.rb b/lib/fluent/event_router.rb
@@ -144,7 +144,6 @@ def initialize
         @filters = []
         @output = nil
         @optimizer = FilterOptimizer.new
-        @unpacker = Fluent::MessagePackFactory.unpacker
       end
 
       def add_filter(filter)
@@ -184,7 +183,7 @@ def filter_stream(tag, es)
 
         def optimized_filter_stream(tag, es)
           new_es = MultiEventStream.new
-          es.each(unpacker: @unpacker) do |time, record|
+          es.each(unpacker: Fluent::MessagePackFactory.thread_local_msgpack_unpacker) do |time, record|
             filtered_record = record
             filtered_time = time