diff --git a/common/src/main/java/org/apache/atlas/service/redis/RedisServiceImpl.java b/common/src/main/java/org/apache/atlas/service/redis/RedisServiceImpl.java index 48f199473e..1f1c97c492 100644 --- a/common/src/main/java/org/apache/atlas/service/redis/RedisServiceImpl.java +++ b/common/src/main/java/org/apache/atlas/service/redis/RedisServiceImpl.java @@ -19,7 +19,7 @@ public class RedisServiceImpl extends AbstractRedisService{ public void init() throws AtlasException { redisClient = Redisson.create(getProdConfig()); redisCacheClient = Redisson.create(getCacheImplConfig()); - LOG.info("Sentinel redis client created successfully."); + LOG.debug("Sentinel redis client created successfully."); } @Override diff --git a/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphDatabase.java b/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphDatabase.java index db69d77ee3..0d96b0e839 100644 --- a/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphDatabase.java +++ b/graphdb/janus/src/main/java/org/apache/atlas/repository/graphdb/janus/AtlasJanusGraphDatabase.java @@ -225,7 +225,7 @@ public static void configureTxLogBasedIndexRecovery() { updateGlobalConfiguration(properties); - LOG.info("Tx Log-based Index Recovery: {}!", recoveryEnabled ? "Enabled" : "Disabled"); + LOG.debug("Tx Log-based Index Recovery: {}!", recoveryEnabled ? "Enabled" : "Disabled"); } catch (Exception e) { LOG.error("Error: Failed!", e); } @@ -243,7 +243,7 @@ private static void updateGlobalConfiguration(Map map) { managementSystem.set(entry.getKey(), entry.getValue()); } - LOG.info("Global properties updated!: {}", map); + LOG.debug("Global properties updated!: {}", map); } catch (Exception ex) { LOG.error("Error updating global configuration: {}", map, ex); } finally { @@ -358,7 +358,7 @@ public AtlasGraph getGraphBulkLoading() { } private static void startEmbeddedSolr() throws AtlasException { - LOG.info("==> startEmbeddedSolr()"); + LOG.debug("==> startEmbeddedSolr()"); try { Class localSolrRunnerClz = Class.forName("org.apache.atlas.runner.LocalSolrRunner"); @@ -371,11 +371,11 @@ private static void startEmbeddedSolr() throws AtlasException { throw new AtlasException("startEmbeddedSolr(): failed", excp); } - LOG.info("<== startEmbeddedSolr()"); + LOG.debug("<== startEmbeddedSolr()"); } private static void stopEmbeddedSolr() throws AtlasException { - LOG.info("==> stopEmbeddedSolr()"); + LOG.debug("==> stopEmbeddedSolr()"); try { Class localSolrRunnerClz = Class.forName("org.apache.atlas.runner.LocalSolrRunner"); @@ -388,7 +388,7 @@ private static void stopEmbeddedSolr() throws AtlasException { throw new AtlasException("stopEmbeddedSolr(): failed", excp); } - LOG.info("<== stopEmbeddedSolr()"); + LOG.debug("<== stopEmbeddedSolr()"); } public static boolean isEmbeddedSolr() { diff --git a/notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java b/notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java index 676a917f96..190bb23b0d 100644 --- a/notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java +++ b/notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java @@ -104,7 +104,7 @@ public class KafkaNotification extends AbstractNotification implements Service { public KafkaNotification(Configuration applicationProperties) throws AtlasException { super(applicationProperties); - LOG.info("==> KafkaNotification()"); + LOG.debug("==> KafkaNotification()"); Configuration kafkaConf = ApplicationProperties.getSubsetConfiguration(applicationProperties, PROPERTY_PREFIX); @@ -138,7 +138,7 @@ public KafkaNotification(Configuration applicationProperties) throws AtlasExcept KafkaUtils.setKafkaJAASProperties(applicationProperties, properties); - LOG.info("<== KafkaNotification()"); + LOG.debug("<== KafkaNotification()"); } @VisibleForTesting diff --git a/repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java b/repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java index a8bacbbb5f..8d736e35d2 100755 --- a/repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java +++ b/repository/src/main/java/org/apache/atlas/repository/graph/GraphBackedSearchIndexer.java @@ -298,24 +298,24 @@ private void initialize(AtlasGraph graph) throws RepositoryException, IndexExcep AtlasGraphManagement management = graph.getManagementSystem(); try { - LOG.info("Creating indexes for graph."); + LOG.debug("Creating indexes for graph."); if (management.getGraphIndex(VERTEX_INDEX) == null) { management.createVertexMixedIndex(VERTEX_INDEX, BACKING_INDEX, Collections.emptyList()); - LOG.info("Created index : {}", VERTEX_INDEX); + LOG.debug("Created index : {}", VERTEX_INDEX); } if (management.getGraphIndex(EDGE_INDEX) == null) { management.createEdgeMixedIndex(EDGE_INDEX, BACKING_INDEX, Collections.emptyList()); - LOG.info("Created index : {}", EDGE_INDEX); + LOG.debug("Created index : {}", EDGE_INDEX); } if (management.getGraphIndex(FULLTEXT_INDEX) == null) { management.createFullTextMixedIndex(FULLTEXT_INDEX, BACKING_INDEX, Collections.emptyList()); - LOG.info("Created index : {}", FULLTEXT_INDEX); + LOG.debug("Created index : {}", FULLTEXT_INDEX); } HashMap ES_DATE_FIELD = new HashMap<>(); @@ -443,7 +443,7 @@ private void initialize(AtlasGraph graph) throws RepositoryException, IndexExcep commit(management); - LOG.info("Index creation for global keys complete."); + LOG.debug("Index creation for global keys complete."); } catch (Throwable t) { LOG.error("GraphBackedSearchIndexer.initialize() failed", t); @@ -850,7 +850,7 @@ public String createVertexIndex(AtlasGraphManagement management, String property } indexFieldName = management.addMixedIndex(VERTEX_INDEX, propertyKey, isStringField, indexTypeESConfig, indexTypeESFields); - LOG.info("Created backing index for vertex property {} of type {} ", propertyName, propertyClass.getName()); + LOG.debug("Created backing index for vertex property {} of type {} ", propertyName, propertyClass.getName()); } if(indexFieldName == null && isIndexApplicable(propertyClass, cardinality)) { diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerDelegate.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerDelegate.java index f1a98fd526..cb04d4f58e 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerDelegate.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerDelegate.java @@ -81,7 +81,7 @@ private DeleteHandlerV1 getDefaultConfiguredHandler(AtlasTypeRegistry typeRegist try { Class handlerFromProperties = AtlasRepositoryConfiguration.getDeleteHandlerV1Impl(); - LOG.info("Default delete handler set to: {}", handlerFromProperties.getName()); + LOG.debug("Default delete handler set to: {}", handlerFromProperties.getName()); ret = (DeleteHandlerV1) handlerFromProperties.getConstructor(AtlasGraph.class, AtlasTypeRegistry.class, TaskManagement.class) .newInstance(this.graph, typeRegistry, taskManagement); diff --git a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasGraphUtilsV2.java b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasGraphUtilsV2.java index 42d30d39ca..a719d4cfbb 100644 --- a/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasGraphUtilsV2.java +++ b/repository/src/main/java/org/apache/atlas/repository/store/graph/v2/AtlasGraphUtilsV2.java @@ -94,7 +94,7 @@ public class AtlasGraphUtilsV2 { } catch (Exception excp) { LOG.error("Error reading configuration", excp); } finally { - LOG.info("atlas.use.index.query.to.find.entity.by.unique.attributes=" + USE_INDEX_QUERY_TO_FIND_ENTITY_BY_UNIQUE_ATTRIBUTES); + LOG.debug("atlas.use.index.query.to.find.entity.by.unique.attributes=" + USE_INDEX_QUERY_TO_FIND_ENTITY_BY_UNIQUE_ATTRIBUTES); } } diff --git a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationSender.java b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationSender.java index ece56f294e..61666f454f 100644 --- a/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationSender.java +++ b/webapp/src/main/java/org/apache/atlas/notification/EntityNotificationSender.java @@ -45,11 +45,11 @@ public EntityNotificationSender(NotificationInterface notificationInterface, Con public EntityNotificationSender(NotificationInterface notificationInterface, boolean sendPostCommit) { if (sendPostCommit) { - LOG.info("EntityNotificationSender: notifications will be sent after transaction commit"); + LOG.debug("EntityNotificationSender: notifications will be sent after transaction commit"); this.notificationSender = new PostCommitNotificationSender(notificationInterface); } else { - LOG.info("EntityNotificationSender: notifications will be sent inline (i.e. not waiting for transaction to commit)"); + LOG.debug("EntityNotificationSender: notifications will be sent inline (i.e. not waiting for transaction to commit)"); this.notificationSender = new InlineNotificationSender(notificationInterface); } diff --git a/webapp/src/main/java/org/apache/atlas/util/AccessAuditLogsIndexCreator.java b/webapp/src/main/java/org/apache/atlas/util/AccessAuditLogsIndexCreator.java index f5786cf7d3..07b693f8b6 100644 --- a/webapp/src/main/java/org/apache/atlas/util/AccessAuditLogsIndexCreator.java +++ b/webapp/src/main/java/org/apache/atlas/util/AccessAuditLogsIndexCreator.java @@ -89,7 +89,7 @@ public class AccessAuditLogsIndexCreator extends Thread { private boolean is_completed = false; public AccessAuditLogsIndexCreator(Configuration configuration) throws IOException { - LOG.info("Starting Ranger audit schema setup in ElasticSearch."); + LOG.debug("Starting Ranger audit schema setup in ElasticSearch."); time_interval = configuration.getLong(ES_TIME_INTERVAL, DEFAULT_ES_TIME_INTERVAL_MS); user = configuration.getString(ES_CONFIG_USERNAME); @@ -124,14 +124,14 @@ private String connectionString() { @Override public void run() { - LOG.info("Started run method"); + LOG.debug("Started run method"); if (CollectionUtils.isNotEmpty(hosts)) { - LOG.info("Elastic search hosts=" + hosts + ", index=" + index); + LOG.debug("Elastic search hosts=" + hosts + ", index=" + index); while (!is_completed && (max_retry == TRY_UNTIL_SUCCESS || retry_counter < max_retry)) { try { - LOG.info("Trying to acquire elastic search connection"); + LOG.debug("Trying to acquire elastic search connection"); if (connect()) { - LOG.info("Connection to elastic search established successfully"); + LOG.debug("Connection to elastic search established successfully"); if (createIndex()) { is_completed = true; break; @@ -232,18 +232,18 @@ private boolean createIndex() { int statusCode = response.getStatusLine().getStatusCode(); if (statusCode == 200) { - LOG.info("Entity audits index exists!"); + LOG.debug("Entity audits index exists!"); exists = true; } else { - LOG.info("Entity audits index does not exist!"); + LOG.debug("Entity audits index does not exist!"); exists = false; } } catch (Exception e) { - LOG.info("Index " + this.index + " not available."); + LOG.warn("Index " + this.index + " not available."); } if (!exists) { - LOG.info("Index does not exist. Attempting to create index:" + this.index); + LOG.debug("Index does not exist. Attempting to create index:" + this.index); try { HttpEntity entity = new NStringEntity(es_ranger_audit_schema_json, ContentType.APPLICATION_JSON); Request request = new Request("PUT", index); @@ -257,7 +257,7 @@ private boolean createIndex() { Response response = client.performRequest(request); if (response != null && response.getStatusLine().getStatusCode() == 200) { - LOG.info("Index " + this.index + " created successfully."); + LOG.debug("Index " + this.index + " created successfully."); exists = true; } } catch (Exception e) { @@ -265,7 +265,7 @@ private boolean createIndex() { e.printStackTrace(); } } else { - LOG.info("Index " + this.index + " is already created."); + LOG.debug("Index " + this.index + " is already created."); } } return exists; diff --git a/webapp/src/main/java/org/apache/atlas/web/listeners/LoginProcessor.java b/webapp/src/main/java/org/apache/atlas/web/listeners/LoginProcessor.java index cc2ef8acc1..2a836b1049 100644 --- a/webapp/src/main/java/org/apache/atlas/web/listeners/LoginProcessor.java +++ b/webapp/src/main/java/org/apache/atlas/web/listeners/LoginProcessor.java @@ -74,7 +74,7 @@ protected void doServiceLogin(Configuration hadoopConfig, getServerPrincipal(configuration.getString(AUTHENTICATION_PRINCIPAL), bindAddress), configuration.getString(AUTHENTICATION_KEYTAB)); } - LOG.info("Logged in user {}", UserGroupInformation.getLoginUser()); + LOG.debug("Logged in user {}", UserGroupInformation.getLoginUser()); } catch (IOException e) { throw new IllegalStateException(String.format("Unable to perform %s login.", authenticationMethod), e); } @@ -99,7 +99,7 @@ protected void setupHadoopConfiguration(Configuration hadoopConfig, org.apache.c String kerberosAuthNEnabled = configuration != null ? configuration.getString(AUTHENTICATION_KERBEROS_METHOD) : null; // getString may return null, and would like to log the nature of the default setting if (kerberosAuthNEnabled == null || kerberosAuthNEnabled.equalsIgnoreCase("false")) { - LOG.info("No authentication method configured. Defaulting to simple authentication"); + LOG.debug("No authentication method configured. Defaulting to simple authentication"); authMethod = "simple"; } else if (kerberosAuthNEnabled.equalsIgnoreCase("true")) { authMethod = "kerberos"; diff --git a/webapp/src/main/java/org/apache/atlas/web/setup/SetupSteps.java b/webapp/src/main/java/org/apache/atlas/web/setup/SetupSteps.java index cfb49b6bf7..e06f451c30 100644 --- a/webapp/src/main/java/org/apache/atlas/web/setup/SetupSteps.java +++ b/webapp/src/main/java/org/apache/atlas/web/setup/SetupSteps.java @@ -186,7 +186,7 @@ public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) LOG.warn("Running setup per configuration {}.", ATLAS_SERVER_RUN_SETUP_KEY); return true; } else { - LOG.info("Not running setup per configuration {}.", ATLAS_SERVER_RUN_SETUP_KEY); + LOG.debug("Not running setup per configuration {}.", ATLAS_SERVER_RUN_SETUP_KEY); } } catch (AtlasException e) { LOG.error("Unable to read config to determine if setup is needed. Not running setup.");