ambari-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dmytro Grinenko (Jira)" <j...@apache.org>
Subject [jira] [Resolved] (AMBARI-25637) ConcurrentModificationException during stomp subscriptions processing
Date Mon, 29 Mar 2021 12:46:00 GMT

     [ 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)

Mime
View raw message