diff --git a/lib/sink/ElasticSinkTask.js b/lib/sink/ElasticSinkTask.js index e5b4618..853c47b 100644 --- a/lib/sink/ElasticSinkTask.js +++ b/lib/sink/ElasticSinkTask.js @@ -64,8 +64,8 @@ class ElasticSinkTask extends SinkTask { this.esClient.bulk({ body, }).then(function (data) { - if (data && data.body && data.errors) { - console.error(data.body); + if (data && data.body && data.body.errors) { + console.error(data.body.errors); } self._stats.totalUpserts += upserts.length; callback();