Merge pull request #2447 from atlanhq/PLT-302

Remove redundant logging
atlanhq · Nov 3, 2023 · 6ef08eb · 6ef08eb
2 parents a48286c + c07cb54
commit 6ef08eb
Show file tree

Hide file tree

Showing 5 changed files with 2 additions and 9 deletions.
diff --git a/auth-agents-common/src/main/java/org/apache/atlas/plugin/util/KeycloakUserStore.java b/auth-agents-common/src/main/java/org/apache/atlas/plugin/util/KeycloakUserStore.java
@@ -153,7 +153,6 @@ public RangerRoles loadRolesIfUpdated(long lastUpdatedTime) throws AtlasBaseExce
 
         boolean isKeycloakUpdated = isKeycloakSubjectsStoreUpdated(lastUpdatedTime);
         if (!isKeycloakUpdated) {
-            LOG.info("loadRolesIfUpdated: Skipping as no update found");
             return null;
         }
 
@@ -272,7 +271,6 @@ public RangerUserStore loadUserStoreIfUpdated(long lastUpdatedTime) throws Atlas
 
         boolean isKeycloakUpdated = isKeycloakSubjectsStoreUpdated(lastUpdatedTime);
         if (!isKeycloakUpdated) {
-            LOG.info("loadUserStoreIfUpdated: Skipping as no update found");
             return null;
         }
 

diff --git a/...s-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java b/...s-common/src/main/java/org/apache/atlas/policytransformer/CachePolicyTransformerImpl.java
@@ -188,9 +188,7 @@ public ServicePolicies getPolicies(String serviceName, String pluginId, Long las
 
                 RequestContext.get().endMetricRecord(recorderFilterPolicies);
 
-                if (LOG.isDebugEnabled()) {
-                    LOG.debug("Found {} policies", servicePolicies.getPolicies().size());
-                }
+                LOG.info("Found {} policies", servicePolicies.getPolicies().size());
             }
 
         } catch (Exception e) {

diff --git a/repository/src/main/java/org/apache/atlas/repository/audit/ESBasedAuditRepository.java b/repository/src/main/java/org/apache/atlas/repository/audit/ESBasedAuditRepository.java
@@ -206,7 +206,6 @@ public List<EntityAuditEventV2> listEventsV2(String entityId, EntityAuditEventV2
 
     @Override
     public EntityAuditSearchResult searchEvents(String queryString) throws AtlasBaseException {
-        LOG.info("Hitting ES query to fetch audits: {}", queryString);
         try {
             String response = performSearchOnIndex(queryString);
             return getResultFromResponse(response);

diff --git a/repository/src/main/java/org/apache/atlas/tasks/TaskQueueWatcher.java b/repository/src/main/java/org/apache/atlas/tasks/TaskQueueWatcher.java
@@ -98,9 +98,9 @@ public void run() {
                 if (CollectionUtils.isNotEmpty(tasks)) {
                     final CountDownLatch latch = new CountDownLatch(tasks.size());
                     submitAll(tasks, latch);
+                    LOG.info("Submitted {} tasks to the queue", tasks.size());
                     waitForTasksToComplete(latch);
                 } else {
-                    LOG.info("No tasks to queue, sleeping for {} ms", pollInterval);
                     redisService.releaseDistributedLock(ATLAS_TASK_LOCK);
                 }
                 Thread.sleep(pollInterval);
@@ -153,7 +153,6 @@ public void run() {
             if (LOG.isDebugEnabled()) {
                 LOG.debug("TasksFetcher: Fetching tasks for queuing");
             }
-            LOG.info("TasksFetcher: Fetching tasks for queuing");
 
             this.tasks = registry.getTasksForReQueue();
         }

diff --git a/webapp/src/main/java/org/apache/atlas/web/rest/AuthREST.java b/webapp/src/main/java/org/apache/atlas/web/rest/AuthREST.java
@@ -209,7 +209,6 @@ private boolean isPolicyUpdated(String serviceName, long lastUpdatedTime) {
             EntityAuditSearchResult result = auditRepository.searchEvents(parameters.getQueryString());
 
             if (result == null || CollectionUtils.isEmpty(result.getEntityAudits())) {
-                LOG.info("getPoliciesIfUpdated: Skipping as no update found");
                 return false;
             }
         } catch (AtlasBaseException e) {