Skip to content

Commit b3749d3

Browse files
committed
indexer fix
1 parent 14727af commit b3749d3

File tree

1 file changed

+1
-2
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer

1 file changed

+1
-2
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,6 @@ public void changeNamespaces(Set<String> namespaces) {
9393
namespaces.forEach(ns -> {
9494
if (!sources.containsKey(ns)) {
9595
final InformerWrapper<T> source = createEventSourceForNamespace(ns);
96-
source.addIndexers(this.indexers);
9796
source.start();
9897
log.debug("Registered new {} -> {} for namespace: {}", this, source,
9998
ns);
@@ -113,6 +112,7 @@ private InformerWrapper<T> createEventSourceForNamespace(String namespace) {
113112
client.inNamespace(namespace).withLabelSelector(configuration.getLabelSelector()),
114113
eventHandler, namespace);
115114
}
115+
source.addIndexers(indexers);
116116
return source;
117117
}
118118

@@ -185,7 +185,6 @@ private Optional<InformerWrapper<T>> getSource(String namespace) {
185185
@Override
186186
public void addIndexers(Map<String, Function<T, List<String>>> indexers) {
187187
this.indexers.putAll(indexers);
188-
sources.values().forEach(s -> s.addIndexers(indexers));
189188
}
190189

191190
@Override

0 commit comments

Comments
 (0)