fix: handle existing document gracefully (#114)

hypertrace · Aug 9, 2022 · 0a35e0e · 0a35e0e
1 parent 148ca1d
commit 0a35e0e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...nt-store/src/main/java/org/hypertrace/core/documentstore/postgres/PostgresCollection.java b/...nt-store/src/main/java/org/hypertrace/core/documentstore/postgres/PostgresCollection.java
@@ -730,7 +730,9 @@ private Optional<Long> getCreatedTime(Key key) throws IOException {
     CloseableIterator<Document> iterator = searchDocsForKeys(Set.of(key));
     if (iterator.hasNext()) {
       JsonNode existingDocument = getDocAsJSON(iterator.next());
-      return Optional.of(existingDocument.get(DocStoreConstants.CREATED_TIME).asLong());
+      if (existingDocument.has(DocStoreConstants.CREATED_TIME)) {
+        return Optional.of(existingDocument.get(DocStoreConstants.CREATED_TIME).asLong());
+      }
     }
     return Optional.empty();
   }