Skip to content

Commit c922a01

Browse files
lburgazzolimetacosm
authored andcommitted
fix: prevent NPE on shutdown if DefaultEventSourceManager.cleanup() is invoked after DefaultEventSourceManeger.close()
1 parent a3d1aa8 commit c922a01

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/DefaultEventSourceManager.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,10 @@ public void cleanup(String customResourceUid) {
144144
.keySet()
145145
.forEach(k -> deRegisterCustomResourceFromEventSource(k, customResourceUid));
146146
eventSources.remove(customResourceUid);
147-
getCache().cleanup(customResourceUid);
147+
CustomResourceCache cache = getCache();
148+
if (cache != null) {
149+
cache.cleanup(customResourceUid);
150+
}
148151
}
149152

150153
// todo: remove

0 commit comments

Comments
 (0)