Revert "Add stepback on finding log groups and procesing groups"

This reverts commit 1256571.

Author: lukewaite

lib/logstash/inputs/cloudwatch_logs.rb

@@ -131,18 +131,9 @@ def find_log_groups
  @logger.debug("log_group prefix is enabled, searching for log groups")
  groups = []
  next_token = nil
- stepback = 1
  @log_group.each do |group|
  loop do
- begin
- log_groups = @cloudwatch.describe_log_groups(log_group_name_prefix: group, next_token: next_token)
- rescue Aws::CloudWatchLogs::Errors::ThrottlingException
- @logger.debug("CloudWatch Logs (find_log_groups) stepping back ", :stepback => 2 * stepback * 60)
- sleep(2 ** stepback * 60)
- stepback += 1
- @logger.debug("CloudWatch Logs (find_log_groups) beginning again with token ", :token => next_token)
- next
- end
+ log_groups = @cloudwatch.describe_log_groups(log_group_name_prefix: group, next_token: next_token)
  groups += log_groups.log_groups.map {|n| n.log_group_name}
  next_token = log_groups.next_token
  @logger.debug("found #{log_groups.log_groups.length} log groups matching prefix #{group}")
@@ -177,7 +168,6 @@ def determine_start_position(groups)
  private
  def process_group(group)
  next_token = nil
- stepback = 1
  loop do
  if !@sincedb.member?(group)
  @sincedb[group] = 0
@@ -188,15 +178,7 @@ def process_group(group)
  :interleaved => true,
  :next_token => next_token
  }
- begin
- resp = @cloudwatch.filter_log_events(params)
- rescue Aws::CloudWatchLogs::Errors::ThrottlingException
- @logger.debug("CloudWatch Logs (process_group) stepping back ", :stepback => 2 * stepback * 60)
- sleep(2 ** stepback * 60)
- stepback += 1
- @logger.debug("CloudWatch Logs (process_group) beginning again with token ", :token => next_token, :log_group_name => group)
- next
- end
+ resp = @cloudwatch.filter_log_events(params)
 
  resp.events.each do |event|
  process_log(event, group)