From efafc6d7d9925f888234b82c8fe20d9ab0341a45 Mon Sep 17 00:00:00 2001 From: Jacob O'Farrell Date: Wed, 29 Jul 2020 08:07:50 +1000 Subject: [PATCH] Fix typo in logging output Closes: https://github.com/snowplow/snowplow-elasticsearch-loader/issues/173 --- .../stream/loader/clients/ElasticsearchBulkSender.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/elasticsearch/src/main/scala/com/snowplowanalytics/stream/loader/clients/ElasticsearchBulkSender.scala b/elasticsearch/src/main/scala/com/snowplowanalytics/stream/loader/clients/ElasticsearchBulkSender.scala index 8b8da057..58194b4b 100644 --- a/elasticsearch/src/main/scala/com/snowplowanalytics/stream/loader/clients/ElasticsearchBulkSender.scala +++ b/elasticsearch/src/main/scala/com/snowplowanalytics/stream/loader/clients/ElasticsearchBulkSender.scala @@ -131,7 +131,7 @@ class ElasticsearchBulkSender( } } else Nil - log.info(s"Emitted ${esObjects.size - newFailures.size} records to Elasticseacrch") + log.info(s"Emitted ${esObjects.size - newFailures.size} records to Elasticsearch") if (newFailures.nonEmpty) logHealth() val allFailures = oldFailures ++ newFailures