Cleanup entries after index rebuild
@@ -1934,8 +1934,10 @@ public class IgniteH2Indexing implements GridQueryIndexing {
KeyCacheObject key = keyIter.next();
while (true) {
+ GridCacheEntryEx entry = null;
+
try {
- GridCacheEntryEx entry = cctx.isNear() ?
+ entry = cctx.isNear() ?
cctx.near().dht().entryEx(key) : cctx.cache().entryEx(key);
entry.ensureIndexed();
@@ -1948,6 +1950,9 @@ public class IgniteH2Indexing implements GridQueryIndexing {
catch (GridDhtInvalidPartitionException ignore) {
break;
}
+ finally {
+ entry.context().evicts().touch(entry, AffinityTopologyVersion.NONE);
+ }
}
}
finally {
