in_cloudwatch_logs: fix error while fetching yesterdays logstream with prefix

ncs29 · ncs29 · commit 6bc5a2c622e0 · 2021-11-16T19:59:37.000+05:30
diff --git a/lib/fluent/plugin/in_cloudwatch_logs.rb b/lib/fluent/plugin/in_cloudwatch_logs.rb
@@ -199,7 +199,7 @@ def run
               log_stream_name_prefix = @use_todays_log_stream ? get_todays_date : @log_stream_name
               begin
                 log_streams = describe_log_streams(log_stream_name_prefix, nil, nil, log_group_name)
-                log_streams.concat(describe_log_streams(get_yesterdays_date)) if @use_todays_log_stream
+                log_streams.concat(describe_log_streams(get_yesterdays_date, nil, nil, log_group_name)) if @use_todays_log_stream
                 log_streams.each do |log_stream|
                   log_stream_name = log_stream.log_stream_name
                   events = get_events(log_group_name, log_stream_name)
