diff --git a/pipelines/ingest-fragmenter/src/main/java/org/gbif/pipelines/fragmenter/record/OccurrenceRecordConverter.java b/pipelines/ingest-fragmenter/src/main/java/org/gbif/pipelines/fragmenter/record/OccurrenceRecordConverter.java
index 44acb5de82..87e65a1ed2 100644
--- a/pipelines/ingest-fragmenter/src/main/java/org/gbif/pipelines/fragmenter/record/OccurrenceRecordConverter.java
+++ b/pipelines/ingest-fragmenter/src/main/java/org/gbif/pipelines/fragmenter/record/OccurrenceRecordConverter.java
@@ -11,7 +11,9 @@
 
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 
+@Slf4j
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public class OccurrenceRecordConverter {
 
@@ -20,7 +22,12 @@ public static Map<String, String> convert(HBaseLockingKeyService keygenService,
 
     Function<OccurrenceRecord, String> keyFn =
         ru -> {
-          Long key = Keygen.getKey(keygenService, useTriplet, useOccurrenceId, ru);
+          Long key = Keygen.getErrorKey();
+          try {
+            key = Keygen.getKey(keygenService, useTriplet, useOccurrenceId, ru);
+          } catch (RuntimeException ex) {
+            log.error(ex.getMessage(), ex);
+          }
           if (Keygen.getErrorKey().equals(key) || !validator.isUnique(key.toString())) {
             return Keygen.getErrorKey().toString();
           }