gbif#291

vjrj · Jun 30, 2020 · b7ee217 · b7ee217
1 parent bdef848
commit b7ee217
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...gmenter/src/main/java/org/gbif/pipelines/fragmenter/record/OccurrenceRecordConverter.java b/...gmenter/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();
           }