diff --git a/lib/fluent/plugin/buf_file.rb b/lib/fluent/plugin/buf_file.rb index 4725f5c9fe..de8a22e0e6 100644 --- a/lib/fluent/plugin/buf_file.rb +++ b/lib/fluent/plugin/buf_file.rb @@ -145,7 +145,11 @@ def resume Dir.glob(escaped_patterns(patterns)) do |path| next unless File.file?(path) - log.debug { "restoring buffer file: path = #{path}" } + if owner.respond_to?(:buffer_config) && owner.buffer_config&.flush_at_shutdown + log.warn { "restoring buffer file: path = #{path}" } + else + log.debug { "restoring buffer file: path = #{path}" } + end m = new_metadata() # this metadata will be overwritten by resuming .meta file content # so it should not added into @metadata_list for now diff --git a/lib/fluent/plugin/buf_file_single.rb b/lib/fluent/plugin/buf_file_single.rb index 225447063e..600f8945f6 100644 --- a/lib/fluent/plugin/buf_file_single.rb +++ b/lib/fluent/plugin/buf_file_single.rb @@ -166,7 +166,11 @@ def resume Dir.glob(escaped_patterns(patterns)) do |path| next unless File.file?(path) - log.debug { "restoring buffer file: path = #{path}" } + if owner.respond_to?(:buffer_config) && owner.buffer_config&.flush_at_shutdown + log.warn { "restoring buffer file: path = #{path}" } + else + log.debug { "restoring buffer file: path = #{path}" } + end m = new_metadata() # this metadata will be updated in FileSingleChunk.new mode = Fluent::Plugin::Buffer::FileSingleChunk.assume_chunk_state(path)