We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3ed0746 commit efafc6dCopy full SHA for efafc6d
elasticsearch/src/main/scala/com/snowplowanalytics/stream/loader/clients/ElasticsearchBulkSender.scala
@@ -131,7 +131,7 @@ class ElasticsearchBulkSender(
131
}
132
} else Nil
133
134
- log.info(s"Emitted ${esObjects.size - newFailures.size} records to Elasticseacrch")
+ log.info(s"Emitted ${esObjects.size - newFailures.size} records to Elasticsearch")
135
if (newFailures.nonEmpty) logHealth()
136
137
val allFailures = oldFailures ++ newFailures
0 commit comments