Commit 55ef909c by Madhan Neethiraj

ATLAS-3135: typedef-delete with empty typedefs result in search failures

parent fad2822f
...@@ -393,9 +393,9 @@ public class AtlasTypeRegistry { ...@@ -393,9 +393,9 @@ public class AtlasTypeRegistry {
if (typeDef != null) { if (typeDef != null) {
addTypeWithNoRefResolve(typeDef); addTypeWithNoRefResolve(typeDef);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.addType({})", typeDef); LOG.debug("<== AtlasTypeRegistry.addType({})", typeDef);
...@@ -421,9 +421,9 @@ public class AtlasTypeRegistry { ...@@ -421,9 +421,9 @@ public class AtlasTypeRegistry {
if (CollectionUtils.isNotEmpty(typeDefs)) { if (CollectionUtils.isNotEmpty(typeDefs)) {
addTypesWithNoRefResolve(typeDefs); addTypesWithNoRefResolve(typeDefs);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.addTypes(length={})", (typeDefs == null ? 0 : typeDefs.size())); LOG.debug("<== AtlasTypeRegistry.addTypes(length={})", (typeDefs == null ? 0 : typeDefs.size()));
...@@ -441,9 +441,9 @@ public class AtlasTypeRegistry { ...@@ -441,9 +441,9 @@ public class AtlasTypeRegistry {
addTypesWithNoRefResolve(typesDef.getClassificationDefs()); addTypesWithNoRefResolve(typesDef.getClassificationDefs());
addTypesWithNoRefResolve(typesDef.getEntityDefs()); addTypesWithNoRefResolve(typesDef.getEntityDefs());
addTypesWithNoRefResolve(typesDef.getRelationshipDefs()); addTypesWithNoRefResolve(typesDef.getRelationshipDefs());
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.addTypes({})", typesDef); LOG.debug("<== AtlasTypeRegistry.addTypes({})", typesDef);
...@@ -457,9 +457,9 @@ public class AtlasTypeRegistry { ...@@ -457,9 +457,9 @@ public class AtlasTypeRegistry {
if (typeDef != null) { if (typeDef != null) {
updateTypeWithNoRefResolve(typeDef); updateTypeWithNoRefResolve(typeDef);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.updateType({})", typeDef); LOG.debug("<== AtlasTypeRegistry.updateType({})", typeDef);
...@@ -473,9 +473,9 @@ public class AtlasTypeRegistry { ...@@ -473,9 +473,9 @@ public class AtlasTypeRegistry {
if (guid != null && typeDef != null) { if (guid != null && typeDef != null) {
updateTypeByGuidWithNoRefResolve(guid, typeDef); updateTypeByGuidWithNoRefResolve(guid, typeDef);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.updateTypeByGuid({})", guid); LOG.debug("<== AtlasTypeRegistry.updateTypeByGuid({})", guid);
...@@ -489,9 +489,9 @@ public class AtlasTypeRegistry { ...@@ -489,9 +489,9 @@ public class AtlasTypeRegistry {
if (name != null && typeDef != null) { if (name != null && typeDef != null) {
updateTypeByNameWithNoRefResolve(name, typeDef); updateTypeByNameWithNoRefResolve(name, typeDef);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.updateEnumDefByName({})", name); LOG.debug("<== AtlasTypeRegistry.updateEnumDefByName({})", name);
...@@ -505,9 +505,9 @@ public class AtlasTypeRegistry { ...@@ -505,9 +505,9 @@ public class AtlasTypeRegistry {
if (CollectionUtils.isNotEmpty(typeDefs)) { if (CollectionUtils.isNotEmpty(typeDefs)) {
updateTypesWithNoRefResolve(typeDefs); updateTypesWithNoRefResolve(typeDefs);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.updateTypes(length={})", (typeDefs == null ? 0 : typeDefs.size())); LOG.debug("<== AtlasTypeRegistry.updateTypes(length={})", (typeDefs == null ? 0 : typeDefs.size()));
...@@ -521,9 +521,9 @@ public class AtlasTypeRegistry { ...@@ -521,9 +521,9 @@ public class AtlasTypeRegistry {
if (typesDef != null) { if (typesDef != null) {
updateTypesWithNoRefResolve(typesDef); updateTypesWithNoRefResolve(typesDef);
}
resolveReferences(); resolveReferences();
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.updateTypes({})", typesDef); LOG.debug("<== AtlasTypeRegistry.updateTypes({})", typesDef);
...@@ -555,10 +555,10 @@ public class AtlasTypeRegistry { ...@@ -555,10 +555,10 @@ public class AtlasTypeRegistry {
removeTypesWithNoRefResolve(typesDef.getClassificationDefs()); removeTypesWithNoRefResolve(typesDef.getClassificationDefs());
removeTypesWithNoRefResolve(typesDef.getEntityDefs()); removeTypesWithNoRefResolve(typesDef.getEntityDefs());
removeTypesWithNoRefResolve(typesDef.getRelationshipDefs()); removeTypesWithNoRefResolve(typesDef.getRelationshipDefs());
}
resolveReferences(); resolveReferences();
} }
}
private void removeTypesWithNoRefResolve(Collection<? extends AtlasBaseTypeDef> typeDefs) { private void removeTypesWithNoRefResolve(Collection<? extends AtlasBaseTypeDef> typeDefs) {
if (CollectionUtils.isNotEmpty(typeDefs)) { if (CollectionUtils.isNotEmpty(typeDefs)) {
...@@ -619,17 +619,17 @@ public class AtlasTypeRegistry { ...@@ -619,17 +619,17 @@ public class AtlasTypeRegistry {
LOG.debug("==> AtlasTypeRegistry.removeTypeByGuid({})", guid); LOG.debug("==> AtlasTypeRegistry.removeTypeByGuid({})", guid);
} }
if (guid != null) {
AtlasBaseTypeDef typeDef = getTypeDefByGuid(guid); AtlasBaseTypeDef typeDef = getTypeDefByGuid(guid);
if (guid != null) {
registryData.removeByGuid(guid); registryData.removeByGuid(guid);
}
resolveReferences(); resolveReferences();
if (typeDef != null) { if (typeDef != null) {
deletedTypes.add(typeDef); deletedTypes.add(typeDef);
} }
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.removeTypeByGuid({})", guid); LOG.debug("<== AtlasTypeRegistry.removeTypeByGuid({})", guid);
...@@ -641,17 +641,17 @@ public class AtlasTypeRegistry { ...@@ -641,17 +641,17 @@ public class AtlasTypeRegistry {
LOG.debug("==> AtlasTypeRegistry.removeTypeByName({})", name); LOG.debug("==> AtlasTypeRegistry.removeTypeByName({})", name);
} }
if (name != null) {
AtlasBaseTypeDef typeDef = getTypeDefByName(name); AtlasBaseTypeDef typeDef = getTypeDefByName(name);
if (name != null) {
registryData.removeByName(name); registryData.removeByName(name);
}
resolveReferences(); resolveReferences();
if (typeDef != null) { if (typeDef != null) {
deletedTypes.add(typeDef); deletedTypes.add(typeDef);
} }
}
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("<== AtlasTypeRegistry.removeEnumDefByName({})", name); LOG.debug("<== AtlasTypeRegistry.removeEnumDefByName({})", name);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment