We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0a68feb commit 5935cc4Copy full SHA for 5935cc4
elasticsearch/src/main/scala/com/snowplowanalytics/stream/loader/clients/ElasticsearchBulkSender.scala
@@ -210,7 +210,7 @@ class ElasticsearchBulkSender(
210
error: Option[String],
211
record: EmitterJsonInput
212
): Option[EmitterJsonInput] = {
213
- error.foreach(e => log.error("Failed to index record in Elasticsearch", e))
+ error.foreach(e => log.error(s"Failed to index record in Elasticsearch: {}", e))
214
error
215
.flatMap { e =>
216
if (
0 commit comments