limit startStream to 100 streams.

shirou · Jun 25, 2018 · 39936f5 · 39936f5
1 parent 8ded768
commit 39936f5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cloudwatch_logs_reader.go b/cloudwatch_logs_reader.go
@@ -78,6 +78,12 @@ func (reader *CloudwatchLogsReader) startStream(stream chan Event, watch bool) {
 		close(stream)
 		return
 	}
+
+	// FilterLogEventsInput can not use more than 100 streams.
+	if len(ss) > 100 {
+		ss = ss[0:99]
+	}
+
 	params := &cloudwatchlogs.FilterLogEventsInput{
 		StartTime:      aws.Int64(aws.TimeUnixMilli(reader.start)),
 		EndTime:        aws.Int64(aws.TimeUnixMilli(reader.end)),