Kirill Tkalenko created IGNITE-12902:
----------------------------------------

             Summary: Concurrent modification in time to iterate by events
                 Key: IGNITE-12902
                 URL: https://issues.apache.org/jira/browse/IGNITE-12902
             Project: Ignite
          Issue Type: Improvement
            Reporter: Kirill Tkalenko
            Assignee: Kirill Tkalenko


{noformat}[10:20:37]W: [org.apache.ignite:ignite-core] [2020-02-20 
10:20:37,324][ERROR][main][CacheExchangeMergeTest9] Failed to pre-stop 
processor: GridProcessorAdapter []
[10:20:37]W: [org.apache.ignite:ignite-core] 
java.util.ConcurrentModificationException
[10:20:37]W: [org.apache.ignite:ignite-core] at 
java.util.ArrayList$Itr.checkForComodification(ArrayList.java:909)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
java.util.ArrayList$Itr.next(ArrayList.java:859)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.onDone(GridDhtPartitionsExchangeFuture.java:2302)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.onDone(GridDhtPartitionsExchangeFuture.java:142)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:464)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager.onKernalStop0(GridCachePartitionExchangeManager.java:821)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter.onKernalStop(GridCacheSharedManagerAdapter.java:120)
[10:20:37]W: [org.apache.ignite:ignite-core] at 
org.apache.ignite.internal.processors.cache.GridCacheProcessor.onKernalStop(GridCacheProcessor.java:972)\{noformat}

In that place we are going over event’s collection, looking for server leave’s 
event:

{code}

for (DiscoveryEvent evt : evts.events()) {

if (serverLeftEvent(evt)) {

for (CacheGroupContext grp : cctx.cache().cacheGroups())

grp.affinityFunction().removeNode(evt.eventNode().id());

}

}

{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to