diff --git a/aws/dynamodb_storage_client.go b/aws/dynamodb_storage_client.go index eb23c8c66162..345a4feed1ed 100644 --- a/aws/dynamodb_storage_client.go +++ b/aws/dynamodb_storage_client.go @@ -204,7 +204,7 @@ func (a dynamoDBStorageClient) BatchWrite(ctx context.Context, input chunk.Write continue } else if ok && awsErr.Code() == validationException { // this write will never work, so the only option is to drop the offending items and continue. - level.Warn(util.Logger).Log("msg", "Data lost while flushing to Dynamo", "err", awsErr) + level.Warn(util.Logger).Log("msg", "Data lost while flushing to DynamoDB", "err", awsErr) level.Debug(util.Logger).Log("msg", "Dropped request details", "requests", requests) util.Event().Log("msg", "ValidationException", "requests", requests) // recording the drop counter separately from recordDynamoError(), as the error code alone may not provide enough context @@ -231,7 +231,7 @@ func (a dynamoDBStorageClient) BatchWrite(ctx context.Context, input chunk.Write } if valuesLeft := outstanding.Len() + unprocessed.Len(); valuesLeft > 0 { - return fmt.Errorf("failed to write chunk, %d values remaining: %s", valuesLeft, backoff.Err()) + return fmt.Errorf("failed to write items to DynamoDB, %d values remaining: %s", valuesLeft, backoff.Err()) } return backoff.Err() }