correct error logging for bulk requests

guyromb · Jun 16, 2019 · 33fa121 · 33fa121
1 parent 53ff70b
commit 33fa121
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/lib/sink/ElasticSinkTask.js b/lib/sink/ElasticSinkTask.js
@@ -62,11 +62,15 @@ class ElasticSinkTask extends SinkTask {
         }
 
         this.esClient.bulk({
-            body
-        }).then(function () {
+            body,
+        }).then(function (data) {
+            if (data && data.body && data.errors) {
+                console.error(data.body);
+            }
             self._stats.totalUpserts += upserts.length;
             callback();
         }).catch((err) => {
+            console.error(err);
             self._stats.bulkUpsertErrors++;
             return callback(err);
         });