Fixed using the wrong map in BatchingIndexSubmittor

geonetwork · Nov 7, 2024 · 83ea448 · 83ea448
1 parent 34e1607
commit 83ea448
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/fao/geonet/kernel/search/submission/BatchingIndexSubmittor.java b/core/src/main/java/org/fao/geonet/kernel/search/submission/BatchingIndexSubmittor.java
@@ -48,11 +48,11 @@ public void run() {
 
         private void sendDocumentsToIndex(Map<String, String> toIndex) {
             EsRestClient restClient = searchManager.getClient();
-            BulkRequest bulkRequest = restClient.buildBulkRequest(searchManager.getDefaultIndex(), listOfDocumentsToIndex);
+            BulkRequest bulkRequest = restClient.buildBulkRequest(searchManager.getDefaultIndex(), toIndex);
             CompletableFuture<Void> currentIndexFuture = restClient.getAsyncClient().bulk(bulkRequest)
                     .thenAcceptAsync(bulkItemResponses -> {
                         try {
-                            searchManager.handleIndexResponse(bulkItemResponses, listOfDocumentsToIndex);
+                            searchManager.handleIndexResponse(bulkItemResponses, toIndex);
                         } catch (IOException e) {
                             throw new UncheckedIOException(e);
                         }