lib/fluent/plugin/parser.rb in fluentd-1.7.4 vs lib/fluent/plugin/parser.rb in fluentd-1.8.0.rc1

@@ -33,9 +33,10 @@
         def initialize(timeout)
           @map = {}
           @flag = ServerEngine::BlockingFlag.new
           @mutex = Mutex.new
           @timeout = timeout
+          @timeout_checker = nil
         end
 
         def start
           @thread = ::Thread.new {
             until @flag.wait_for_set(0.5)