Skip to content

Commit 66dd19c

Browse files
fix: clean up imports and use Set.copyOf for snapshot in fullyRefreshCache
Agent-Logs-Url: https://github.com/kubernetes-client/java/sessions/07e0048a-55b8-42c1-809c-ff20e3bd4837 Co-authored-by: brendandburns <5751682+brendandburns@users.noreply.github.com>
1 parent b609abe commit 66dd19c

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

spring/src/main/java/io/kubernetes/client/spring/extended/manifests/KubernetesFromConfigMapProcessor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import io.kubernetes.client.spring.extended.manifests.configmaps.ConfigMapGetter;
2121
import java.lang.reflect.Field;
2222
import java.util.Map;
23+
import java.util.Set;
2324
import java.util.concurrent.Executors;
2425
import java.util.concurrent.ScheduledExecutorService;
2526
import java.util.concurrent.TimeUnit;
@@ -104,9 +105,8 @@ private static void fullyRefreshCache(
104105
// TODO: make the cache data refreshment atomic
105106
Map<String, String> newData = configMap.getData();
106107
newData.forEach(configMapDataCache::put);
107-
configMapDataCache.asMap().keySet().stream()
108+
Set.copyOf(configMapDataCache.asMap().keySet()).stream()
108109
.filter(key -> !newData.containsKey(key))
109-
.collect(java.util.stream.Collectors.toList())
110110
.forEach(configMapDataCache::invalidate);
111111
}
112112

0 commit comments

Comments
 (0)