[ https://issues.apache.org/jira/browse/AMBARI-25637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dmytro Grinenko resolved AMBARI-25637. -------------------------------------- Assignee: Dmytro Grinenko Resolution: Fixed > ConcurrentModificationException during stomp subscriptions processing > --------------------------------------------------------------------- > > Key: AMBARI-25637 > URL: https://issues.apache.org/jira/browse/AMBARI-25637 > Project: Ambari > Issue Type: Bug > Components: ambari-server > Affects Versions: 2.7.5 > Reporter: Dmytro Vitiuk > Assignee: Dmytro Grinenko > Priority: Major > Fix For: 2.7.6 > > Time Spent: 20m > Remaining Estimate: 0h > > AmbariSubscriptionRegistry$DestinationCache's accessCache is not always > processed thread-safely: > {noformat} > Exception in thread "clientInboundChannel-11113" Exception in thread > "clientInboundChannel-11128" > org.springframework.messaging.MessageDeliveryException: Failed to handle > GenericMessage [payload=byte[0], headers={simpMessageType=DISCONNECT, > stompCommand=DISCONNECT, > nativeHeaders={receipt=[17ff2f6e-d783-416e-bbc5-ce7d16bf784b]}, > simpSessionAttributes={org.springframework.messaging.simp.SimpAttributes.COMPLETED=true}, > simpHeartbeat=[J@3ed4c84a, > simpSessionId=d0b10fb8-4f24-9b44-f9b6-71a12baa18c2}] to > org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask@301331e0 > in SimpleBrokerMessageHandler [DefaultSubscriptionRegistry[cache[7378 > destination(s)], registry[904 sessions]]]; nested exception is > java.util.ConcurrentModificationException, failedMessage=GenericMessage > [payload=byte[0], headers={simpMessageType=DISCONNECT, > stompCommand=DISCONNECT, > nativeHeaders={receipt=[17ff2f6e-d783-416e-bbc5-ce7d16bf784b]}, > simpSessionAttributes={org.springframework.messaging.simp.SimpAttributes.COMPLETED=true}, > simpHeartbeat=[J@3ed4c84a, > simpSessionId=d0b10fb8-4f24-9b44-f9b6-71a12baa18c2}] > at > org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask.run(ExecutorSubscribableChannel.java:153) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.util.ConcurrentModificationException > at > java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:719) > at > java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:752) > at > java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:750) > at java.util.Map.forEach(Map.java:620) > at > org.springframework.util.LinkedMultiValueMap.deepCopy(LinkedMultiValueMap.java:83) > at > org.apache.ambari.server.agent.stomp.AmbariSubscriptionRegistry$DestinationCache.updateAfterRemovedSession(AmbariSubscriptionRegistry.java:327) > at > org.apache.ambari.server.agent.stomp.AmbariSubscriptionRegistry.unregisterAllSubscriptions(AmbariSubscriptionRegistry.java:177) > at > org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.handleDisconnect(SimpleBrokerMessageHandler.java:368) > at > org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.handleMessageInternal(SimpleBrokerMessageHandler.java:330) > at > org.springframework.messaging.simp.broker.AbstractBrokerMessageHandler.handleMessage(AbstractBrokerMessageHandler.java:256) > at > org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask.run(ExecutorSubscribableChannel.java:144) > ... 3 more > {noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)