Merge pull request #3655 from atlanhq/MM-3720

MM-3720 Skip corrupted vertex
atlanhq · Oct 23, 2024 · d630958 · d630958
2 parents d1222c4 + 6a68c4f
commit d630958
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...sitory/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphRetriever.java b/...sitory/src/main/java/org/apache/atlas/repository/store/graph/v2/EntityGraphRetriever.java
@@ -1689,7 +1689,16 @@ private AtlasStruct mapVertexToStruct(AtlasVertex entityVertex, String edgeLabel
 
         if (GraphHelper.elementExists(edge)) {
             final AtlasVertex referenceVertex = edge.getInVertex();
-            ret = new AtlasStruct(getTypeName(referenceVertex));
+
+            String typeName = getTypeName(referenceVertex);
+
+            if (StringUtils.isEmpty(typeName)) {
+                LOG.error("typeName not found for in-vertex {} on edge {} from vertex {} ",
+                        getGuid(referenceVertex), edge.getId(), getGuid(entityVertex));
+                return ret;
+            }
+
+            ret = new AtlasStruct(typeName);
 
             mapAttributes(referenceVertex, ret, entityExtInfo, isMinExtInfo);
         }