diff --git a/lib/fluent/plugin/out_elasticsearch_data_stream.rb b/lib/fluent/plugin/out_elasticsearch_data_stream.rb index d2d7f0a..8061eb9 100644 --- a/lib/fluent/plugin/out_elasticsearch_data_stream.rb +++ b/lib/fluent/plugin/out_elasticsearch_data_stream.rb @@ -142,7 +142,7 @@ def data_stream_exist?(datastream_name, host = nil) response = client(host).indices.get_data_stream(params) return (not response.is_a?(TRANSPORT_CLASS::Transport::Errors::NotFound)) rescue TRANSPORT_CLASS::Transport::Errors::NotFound => e - log.info "Specified data stream does not exist. Will be created: <#{e}>" + log.info "Specified data stream does not exist. Will be created: <#{datastream_name}>" return false end end