Skip to content

Commit 83b479d

Browse files
committed
MLH-1199 add logs for debugging
1 parent dc8f3a5 commit 83b479d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

common/src/main/java/org/apache/atlas/service/redis/RedisServiceImpl.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ public void init() throws InterruptedException {
4343
break;
4444
} catch (Exception e) {
4545
LOG.warn("Redis connection failed: {}. Application startup is BLOCKED. Retrying in {} seconds...", e.getMessage(), RETRY_DELAY_MS / 1000);
46-
MetricUtils.recordRedisConnectionFailure();
46+
//MetricUtils.recordRedisConnectionFailure();
4747
// Clean up any partially created clients before retrying.
4848
shutdownClients();
4949
Thread.sleep(RETRY_DELAY_MS);
@@ -60,7 +60,7 @@ private void testRedisConnectivity() throws Exception {
6060

6161
try {
6262
// Test cache client
63-
LOG.debug("Testing Redis cache client connectivity");
63+
LOG.info("Testing Redis cache client connectivity");
6464
redisCacheClient.getBucket(testKey).set(testValue);
6565
String retrievedValue = (String) redisCacheClient.getBucket(testKey).get();
6666

@@ -69,10 +69,10 @@ private void testRedisConnectivity() throws Exception {
6969
}
7070

7171
redisCacheClient.getBucket(testKey).delete();
72-
LOG.debug("Redis connectivity test completed successfully");
72+
LOG.info("Redis connectivity test completed successfully");
7373

7474
} catch (Exception e) {
75-
MetricUtils.recordRedisConnectionFailure();
75+
//MetricUtils.recordRedisConnectionFailure();
7676
throw new Exception("Redis connectivity test failed", e);
7777
}
7878
}

0 commit comments

Comments
 (0)