Skip to content

Commit 8c3731e

Browse files
Jokseragoncharuk
authored andcommitted
IGNITE-6113 Return back old implementation instead of 'removeIf' - Fixes apache#3609.
Signed-off-by: Alexey Goncharuk <[email protected]>
1 parent 64d920b commit 8c3731e

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java

+6-1
Original file line numberDiff line numberDiff line change
@@ -1194,7 +1194,12 @@ private void clearDeferredDeletes() {
11941194
void onCacheStopped(int cacheId) {
11951195
assert grp.sharedGroup() : grp.cacheOrGroupName();
11961196

1197-
rmvQueue.removeIf(e -> e.cacheId() == cacheId);
1197+
for (Iterator<RemovedEntryHolder> it = rmvQueue.iterator(); it.hasNext();) {
1198+
RemovedEntryHolder e = it.next();
1199+
1200+
if (e.cacheId() == cacheId)
1201+
it.remove();
1202+
}
11981203

11991204
cacheMaps.remove(cacheId);
12001205
}

0 commit comments

Comments
 (0)