Merge pull request #131 from tonobo/buffer-flush-failure

out_opensearch_data_stream: Early return on empty body
fluent · Apr 30, 2024 · 6a4b186 · 6a4b186
2 parents 89fe756 + 5f5333c
commit 6a4b186
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/fluent/plugin/out_opensearch_data_stream.rb b/lib/fluent/plugin/out_opensearch_data_stream.rb
@@ -201,6 +201,8 @@ def write(chunk)
         end
       end
 
+      return if bulk_message.to_s.empty?
+
       params = {
         index: data_stream_name,
         body: bulk_message