fixed error on config reload (#235)

splunk · Apr 18, 2022 · b8f798d · b8f798d
1 parent 118d233
commit b8f798d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/lib/fluent/plugin/out_splunk.rb b/lib/fluent/plugin/out_splunk.rb
@@ -92,6 +92,10 @@ def configure(conf)
       end
     end
 
+    def shutdown
+      super
+    end
+
     def write(chunk)
       log.trace { "#{self.class}: Received new chunk, size=#{chunk.read.bytesize}" }
 

diff --git a/lib/fluent/plugin/out_splunk_hec.rb b/lib/fluent/plugin/out_splunk_hec.rb
@@ -169,8 +169,8 @@ def start
     end
 
     def shutdown
+      @conn.shutdown if not @conn.nil?
       super
-      @conn.shutdown
     end
 
     def format(tag, time, record)
-Original file line number
+Diff line change
@@ Expand Up / @@ -92,6 +92,10 @@ def configure(conf) @@
           end
         end
+        def shutdown
+          super
+        end
         def write(chunk)
           log.trace { "#{self.class}: Received new chunk, size=#{chunk.read.bytesize}" }
@@ Expand Down @@