Log if bulk indexing fails (#475)

hbz · Aug 18, 2023 · 8e9c359 · 8e9c359
1 parent cb1ab1d
commit 8e9c359
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/app/controllers/Index.java b/app/controllers/Index.java
@@ -9,6 +9,7 @@
 import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
 import org.elasticsearch.action.admin.indices.refresh.RefreshRequest;
 import org.elasticsearch.action.bulk.BulkRequestBuilder;
+import org.elasticsearch.action.bulk.BulkResponse;
 import org.elasticsearch.action.get.GetResponse;
 import org.elasticsearch.action.search.SearchRequestBuilder;
 import org.elasticsearch.action.search.SearchResponse;
@@ -206,7 +207,10 @@ static void indexData(final Client aClient, final String aPath,
 						StandardCharsets.UTF_8))) {
 			readData(bulkRequest, br, aClient, aIndex);
 		}
-		bulkRequest.execute().actionGet();
+		BulkResponse bulkResponse = bulkRequest.execute().actionGet();
+		if (bulkResponse.hasFailures()) {
+			Logger.warn("Bulk insert failed: " + bulkResponse.buildFailureMessage());
+		}
 		aClient.admin().indices().refresh(new RefreshRequest()).actionGet();
 	}