You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ambari.apache.org by "G. Szabi (Jira)" <ji...@apache.org> on 2021/03/27 13:11:00 UTC
[jira] [Commented] (AMBARI-25637) ConcurrentModificationException
during stomp subscriptions processing
[ https://issues.apache.org/jira/browse/AMBARI-25637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309944#comment-17309944 ]
G. Szabi commented on AMBARI-25637:
-----------------------------------
We are testing the opportunity, I hope we succeed in the integration process. 🙏
> 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
> Priority: Major
> Fix For: 2.7.6
>
> Time Spent: 10m
> 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)