This is an automated email from the ASF dual-hosted git repository.
abhay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ranger.git
The following commit(s) were added to refs/heads/master by this push:
new 48a635c30 RANGER-4115: Tags containing attributes not processed
correctly by tagsync
48a635c30 is described below
commit 48a635c30ac2afe4492f06d132cc517431933dd8
Author: Abhay Kulkarni <[email protected]>
AuthorDate: Thu Mar 2 17:16:21 2023 -0800
RANGER-4115: Tags containing attributes not processed correctly by tagsync
---
.../ranger/tagsync/source/atlas/AtlasNotificationMapper.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasNotificationMapper.java
b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasNotificationMapper.java
index dadc76a54..a7c456b3d 100644
---
a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasNotificationMapper.java
+++
b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasNotificationMapper.java
@@ -351,9 +351,14 @@ public class AtlasNotificationMapper {
RangerTagDef tagDef = new RangerTagDef(tag.getName(),
"Atlas");
if (MapUtils.isNotEmpty(tag.getAttributes())) {
+ List<RangerTagAttributeDef> attributeDefs =
tagDef.getAttributeDefs();
+ if (attributeDefs == null) {
+ attributeDefs = new ArrayList<>();
+ }
for (String attributeName :
tag.getAttributes().keySet()) {
- tagDef.getAttributeDefs().add(new
RangerTagAttributeDef(attributeName,
entityWithTags.getTagAttributeType(tag.getName(), attributeName)));
+ attributeDefs.add(new
RangerTagAttributeDef(attributeName,
entityWithTags.getTagAttributeType(tag.getName(), attributeName)));
}
+ tagDef.setAttributeDefs(attributeDefs);
}
ret.add(tagDef);
}