Minor cleanup
diff --git a/tagsync/src/main/java/org/apache/ranger/tagsync/process/TagSynchronizer.java b/tagsync/src/main/java/org/apache/ranger/tagsync/process/TagSynchronizer.java
index a9098be..d36ecae 100644
--- a/tagsync/src/main/java/org/apache/ranger/tagsync/process/TagSynchronizer.java
+++ b/tagsync/src/main/java/org/apache/ranger/tagsync/process/TagSynchronizer.java
@@ -271,7 +271,7 @@
}
if (LOG.isDebugEnabled()) {
- LOG.debug("<== TagSynchronizer.initializeTagSources(initilaizedTagSources=" + initializedTagSourceNameList
+ LOG.debug("<== TagSynchronizer.initializeTagSources(initializedTagSources=" + initializedTagSourceNameList
+ ", failedTagSources=" + failedTagSources + ")");
}
}
diff --git a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasKafkaResourceMapper.java b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasKafkaResourceMapper.java
index 272328e..9f1fc2d 100644
--- a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasKafkaResourceMapper.java
+++ b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasKafkaResourceMapper.java
@@ -70,8 +70,6 @@
String entityGuid = entity.getId() != null ? entity.getId()._getId() : null;
String serviceName = getRangerServiceName(clusterName);
- RangerServiceResource ret = new RangerServiceResource(entityGuid, serviceName, elements);
-
- return ret;
+ return new RangerServiceResource(entityGuid, serviceName, elements);
}
}
diff --git a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasResourceMapperUtil.java b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasResourceMapperUtil.java
index b8f5c46..f9f0eaf 100644
--- a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasResourceMapperUtil.java
+++ b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlas/AtlasResourceMapperUtil.java
@@ -75,7 +75,7 @@
}
static public boolean initializeAtlasResourceMappers(Properties properties) {
- final String MAPPER_NAME_DELIMIER = ",";
+ final String MAPPER_NAME_DELIMITER = ",";
String customMapperNames = TagSyncConfig.getCustomAtlasResourceMappers(properties);
@@ -91,14 +91,14 @@
mapperNames.add("org.apache.ranger.tagsync.source.atlas.AtlasKafkaResourceMapper");
if (StringUtils.isNotBlank(customMapperNames)) {
- for(String customMapperName : customMapperNames.split(MAPPER_NAME_DELIMIER)) {
+ for (String customMapperName : customMapperNames.split(MAPPER_NAME_DELIMITER)) {
mapperNames.add(customMapperName.trim());
}
}
for (String mapperName : mapperNames) {
try {
- Class clazz = Class.forName(mapperName);
+ Class<?> clazz = Class.forName(mapperName);
AtlasResourceMapper resourceMapper = (AtlasResourceMapper) clazz.newInstance();
resourceMapper.initialize(properties);
diff --git a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlasrest/AtlasRESTUtil.java b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlasrest/AtlasRESTUtil.java
index cca7caf..bf09cfd 100644
--- a/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlasrest/AtlasRESTUtil.java
+++ b/tagsync/src/main/java/org/apache/ranger/tagsync/source/atlasrest/AtlasRESTUtil.java
@@ -105,7 +105,7 @@
if (!AtlasResourceMapperUtil.isEntityTypeHandled(type)) {
if (LOG.isDebugEnabled()) {
- LOG.debug("Not fetching Atlas entities of type:" + type);
+ LOG.debug("Not fetching Atlas entities of type: " + type);
}
continue;
}
@@ -116,7 +116,7 @@
if (CollectionUtils.isEmpty(guids)) {
if (LOG.isDebugEnabled()) {
- LOG.debug("No Atlas entities for type:" + type);
+ LOG.debug("No Atlas entities for type: " + type);
}
continue;
}
