Update IndexingService.java

geonetwork · Mar 1, 2024 · c0349b4 · c0349b4
1 parent e33a362
commit c0349b4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/modules/services/indexing/src/main/java/org/fao/geonet/indexing/service/IndexingService.java b/modules/services/indexing/src/main/java/org/fao/geonet/indexing/service/IndexingService.java
@@ -8,6 +8,7 @@
 
 import co.elastic.clients.elasticsearch.ElasticsearchClient;
 import co.elastic.clients.elasticsearch._types.AcknowledgedResponse;
+import co.elastic.clients.elasticsearch._types.ElasticsearchException;
 import co.elastic.clients.elasticsearch._types.Refresh;
 import co.elastic.clients.elasticsearch.core.BulkRequest;
 import co.elastic.clients.elasticsearch.core.BulkResponse;
@@ -249,10 +250,10 @@ private void sendToIndex(IndexRecords indexRecords,
             failureCount
         ));
       }
-    } catch (IOException ioException) {
+    } catch (ElasticsearchException | IOException esException) {
       log.error(String.format(
           "Error while sending records to index. Error is: %s.",
-          ioException.getMessage()
+              esException.getMessage()
       ));
     }
   }