Skip to content

Commit 22d8c55

Browse files
committed
updating obsolete event handling
# Conflicts: # operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java
1 parent 571b94e commit 22d8c55

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,12 +119,12 @@ private synchronized boolean onEvent(T resource, boolean unknownState, boolean d
119119
int comp = 0;
120120
if (cached != null) {
121121
comp = ReconcileUtils.validateAndCompareResourceVersions(resource, cached);
122-
if (comp > 0 || unknownState) {
122+
if (comp >= 0 || unknownState) {
123123
cache.remove(resourceId);
124124
// we propagate event only for our update or newer other can be discarded since we know we
125125
// will receive
126126
// additional event
127-
obsoleteEvent = false;
127+
obsoleteEvent = comp == 0;
128128
} else {
129129
obsoleteEvent = true;
130130
}

0 commit comments

Comments
 (0)