Skip to content

Commit 34f72fe

Browse files
committed
remove other redis implementations
1 parent 7e06e58 commit 34f72fe

File tree

5 files changed

+2
-110
lines changed

5 files changed

+2
-110
lines changed

.github/workflows/maven.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ on:
3131
- tagscanarymerge
3232
- fixlabels
3333
- interceptapis
34-
- mlh-1240-custom-metadata-consistency
34+
- fix-redis-wiring
3535

3636
jobs:
3737
build:

common/src/main/java/org/apache/atlas/service/FeatureFlagStore.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package org.apache.atlas.service;
22

3-
import org.apache.atlas.service.redis.NoRedisServiceImpl;
43
import org.apache.atlas.service.redis.RedisService;
54
import org.apache.commons.lang.StringUtils;
65
import org.springframework.beans.BeansException;
@@ -106,10 +105,6 @@ public void initialize() throws InterruptedException {
106105
private void validateDependencies() {
107106
LOG.info("Validating FeatureFlagStore dependencies...");
108107
try {
109-
if (redisService instanceof NoRedisServiceImpl) {
110-
return;
111-
}
112-
113108
// Test Redis connectivity with a simple operation
114109
String testKey = "ff:_health_check";
115110
redisService.putValue(testKey, "test");

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

Lines changed: 0 additions & 52 deletions
This file was deleted.

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package org.apache.atlas.service.redis;
22

33
import org.apache.atlas.AtlasException;
4-
import org.apache.atlas.annotation.ConditionalOnAtlasProperty;
54
import org.apache.atlas.service.metrics.MetricUtils;
65
import org.redisson.Redisson;
76
import org.slf4j.Logger;
@@ -13,9 +12,8 @@
1312
import javax.annotation.PostConstruct;
1413

1514
@Component
16-
@ConditionalOnAtlasProperty(property = "atlas.redis.service.impl")
1715
@Order(Ordered.HIGHEST_PRECEDENCE)
18-
public class RedisServiceImpl extends AbstractRedisService{
16+
public class RedisServiceImpl extends AbstractRedisService {
1917

2018
private static final Logger LOG = LoggerFactory.getLogger(RedisServiceImpl.class);
2119
private static final long RETRY_DELAY_MS = 1000L;

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

Lines changed: 0 additions & 49 deletions
This file was deleted.

0 commit comments

Comments
 (0)