feat: just add few logs and connection limit

atlanhq · Nov 8, 2024 · 06322d3 · 06322d3 · sriram-atlan · Nov 8, 2024
1 parent a7844cf
commit 06322d3
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 8 deletions.
diff --git a/common/src/main/java/org/apache/atlas/service/redis/AbstractRedisService.java b/common/src/main/java/org/apache/atlas/service/redis/AbstractRedisService.java
@@ -131,12 +131,12 @@ Config getProdConfig() throws AtlasException {
         config.useSentinelServers()
                 .setClientName(ATLAS_METASTORE_SERVICE)
                 .setReadMode(ReadMode.MASTER_SLAVE)
-                .setCheckSentinelsList(true)
+                .setCheckSentinelsList(false)
                 .setKeepAlive(true)
-                .setMasterConnectionMinimumIdleSize(10)
-                .setMasterConnectionPoolSize(20)
-                .setSlaveConnectionMinimumIdleSize(10)
-                .setSlaveConnectionPoolSize(20)
+                .setMasterConnectionMinimumIdleSize(2)
+                .setMasterConnectionPoolSize(5)
+                .setSlaveConnectionMinimumIdleSize(2)
+                .setSlaveConnectionPoolSize(5)
                 .setMasterName(atlasConfig.getString(ATLAS_REDIS_MASTER_NAME))
                 .addSentinelAddress(formatUrls(atlasConfig.getStringArray(ATLAS_REDIS_SENTINEL_URLS)))
                 .setUsername(atlasConfig.getString(ATLAS_REDIS_USERNAME))
@@ -149,12 +149,12 @@ Config getCacheImplConfig() {
         config.useSentinelServers()
                 .setClientName(ATLAS_METASTORE_SERVICE+"-redisCache")
                 .setReadMode(ReadMode.MASTER_SLAVE)
-                .setCheckSentinelsList(true)
+                .setCheckSentinelsList(false)
                 .setKeepAlive(true)
                 .setMasterConnectionMinimumIdleSize(10)
-                .setMasterConnectionPoolSize(20)
+                .setMasterConnectionPoolSize(2)
                 .setSlaveConnectionMinimumIdleSize(10)
-                .setSlaveConnectionPoolSize(20)
+                .setSlaveConnectionPoolSize(2)
                 .setMasterName(atlasConfig.getString(ATLAS_REDIS_MASTER_NAME))
                 .addSentinelAddress(formatUrls(atlasConfig.getStringArray(ATLAS_REDIS_SENTINEL_URLS)))
                 .setUsername(atlasConfig.getString(ATLAS_REDIS_USERNAME))

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
@@ -17,7 +17,9 @@ public class RedisServiceImpl extends AbstractRedisService{
 
     @PostConstruct
     public void init() throws AtlasException {
+        LOG.info("Starting prod lock redisson client");
         redisClient = Redisson.create(getProdConfig());
+        LOG.info("Starting prod cache redisson client");
         redisCacheClient = Redisson.create(getCacheImplConfig());
         LOG.info("Sentinel redis client created successfully.");
     }

diff --git a/repository/src/main/java/org/apache/atlas/repository/graph/TypeCacheRefresher.java b/repository/src/main/java/org/apache/atlas/repository/graph/TypeCacheRefresher.java
@@ -45,6 +45,7 @@ public TypeCacheRefresher(final IAtlasGraphProvider provider) {
 
     @PostConstruct
     public void init() throws AtlasException {
+        LOG.info("Starting type cache refresher");
         Configuration configuration = ApplicationProperties.get();
         this.cacheRefresherEndpoint = configuration.getString("atlas.server.type.cache-refresher");
         this.cacheRefresherHealthEndpoint = configuration.getString("atlas.server.type.cache-refresher-health");

diff --git a/repository/src/main/java/org/apache/atlas/tasks/TaskFactoryRegistry.java b/repository/src/main/java/org/apache/atlas/tasks/TaskFactoryRegistry.java
@@ -44,6 +44,7 @@ public TaskFactoryRegistry(TaskManagement taskManagement, Set<TaskFactory> facto
 
     @PostConstruct
     public void startTaskManagement() throws AtlasException {
+        LOG.info("Starting task management post-construct");
         try {
             if (taskManagement.isWatcherActive()) {
                 LOG.info("TaskFactoryRegistry: TaskManagement already started!");