Fix Kinesis/Firehose error messages (#1316)

Previously we unintentionally logged the *pointer* when we intended to
log the *value* of how many records failed.
This commit is contained in:
Zach Wasserman
2021-07-12 10:18:02 -07:00
committed by GitHub
parent 29e900d7c3
commit bc1698767e
3 changed files with 3 additions and 2 deletions
+1
View File
@@ -0,0 +1 @@
* Fix printing of failed record count in AWS Kinesis/Firehose logging plugins.
+1 -1
View File
@@ -178,7 +178,7 @@ func (f *firehoseLogWriter) putRecordBatch(try int, records []*firehose.Record)
return errors.Errorf(
"failed to put %d records, retries exhausted. First error: %s",
output.FailedPutCount, errMsg,
*output.FailedPutCount, errMsg,
)
}
+1 -1
View File
@@ -186,7 +186,7 @@ func (k *kinesisLogWriter) putRecords(try int, records []*kinesis.PutRecordsRequ
return errors.Errorf(
"failed to put %d records, retries exhausted. First error: %s",
output.FailedRecordCount, errMsg,
*output.FailedRecordCount, errMsg,
)
}