lib/fluent/plugin/in_tail.rb in fluentd-1.7.4 vs lib/fluent/plugin/in_tail.rb in fluentd-1.8.0.rc1
- old
+ new
@@ -202,9 +202,15 @@
refresh_watchers unless @skip_refresh_on_startup
timer_execute(:in_tail_refresh_watchers, @refresh_interval, &method(:refresh_watchers))
end
+ def stop
+ @@pos_file_paths.delete(@pos_file)
+
+ super
+ end
+
def shutdown
# during shutdown phase, don't close io. It should be done in close after all threads are stopped. See close.
stop_watchers(@tails.keys, immediate: true, remove_watcher: false)
@pf_file.close if @pf_file