bulk error logs

guyromb · Sep 6, 2019 · 47e73fc · 47e73fc
1 parent 33fa121
commit 47e73fc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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();