lib/fluent/plugin/in_systemd.rb in fluent-plugin-systemd-1.0.4 vs lib/fluent/plugin/in_systemd.rb in fluent-plugin-systemd-1.0.5

@@ -19,11 +19,11 @@
 require 'fluent/plugin/systemd/entry_mutator'
 
 module Fluent
   module Plugin
     # Fluentd plugin for reading from the systemd journal
-    class SystemdInput < Input
+    class SystemdInput < Input # rubocop:disable Metrics/ClassLength
       Fluent::Plugin.register_input('systemd', self)
 
       helpers :timer, :storage
 
       DEFAULT_STORAGE_TYPE = 'local'
@@ -61,9 +61,13 @@
         timer_execute(:in_systemd_emit_worker, 1, &method(:run))
       end
 
       def shutdown
         @running = false
+        @journal&.close
+        @journal = nil
+        @pos_storage = nil
+        @mutator = nil
         super
       end
 
       private