You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ambari.apache.org by "Myroslav Papirkovskyi (JIRA)" <ji...@apache.org> on 2019/01/24 13:13:00 UTC
[jira] [Resolved] (AMBARI-25111) Intermittent
ConcurrentModificationException exception during STOMP message emitting
[ https://issues.apache.org/jira/browse/AMBARI-25111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Myroslav Papirkovskyi resolved AMBARI-25111.
--------------------------------------------
Resolution: Fixed
Merged to trunk
> Intermittent ConcurrentModificationException exception during STOMP message emitting
> ------------------------------------------------------------------------------------
>
> Key: AMBARI-25111
> URL: https://issues.apache.org/jira/browse/AMBARI-25111
> Project: Ambari
> Issue Type: Bug
> Components: ambari-server
> Affects Versions: 2.8.0
> Reporter: Myroslav Papirkovskyi
> Assignee: Myroslav Papirkovskyi
> Priority: Critical
> Labels: pull-request-available
> Fix For: 2.8.0
>
> Time Spent: 1h 10m
> Remaining Estimate: 0h
>
> During 2k cluster deploying a lot of exceptions were found in the ambari-server log:
> {code}
> 2019-01-15 16:25:33,567 ERROR [stomp-agent-bus-0] agent-update-bus:232 - Exception thrown by subscriber method onUpdateEvent(org.apache.ambari.server.events.STOMPEvent) on subscriber org.apache.ambari.server.events.listeners.requests.STOMPUpdateListener@5ee973ee when dispatching event: org.apache.ambari.server.events.TopologyAgentUpdateEvent@f4bf3c68
> org.springframework.messaging.MessageDeliveryException: Failed to handle GenericMessage [payload=byte[577], headers={simpMessageType=MESSAGE, contentType=application/json;charset=UTF-8, simpDestination=/events/topologies}] to org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask@13106eff in SimpleBrokerMessageHandler [DefaultSubscriptionRegistry[cache[5480 destination(s)], registry[2392 sessions]]]; nested exception is java.util.ConcurrentModificationException, failedMessage=GenericMessage [payload=byte[577], headers={simpMessageType=MESSAGE, contentType=application/json;charset=UTF-8, simpDestination=/events/topologies}]
> at org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask.run(ExecutorSubscribableChannel.java:153)
> at org.springframework.messaging.support.ExecutorSubscribableChannel.sendInternal(ExecutorSubscribableChannel.java:100)
> at org.springframework.messaging.support.AbstractMessageChannel.send(AbstractMessageChannel.java:136)
> at org.springframework.messaging.support.AbstractMessageChannel.send(AbstractMessageChannel.java:122)
> at org.springframework.messaging.simp.SimpMessagingTemplate.sendInternal(SimpMessagingTemplate.java:187)
> at org.springframework.messaging.simp.SimpMessagingTemplate.doSend(SimpMessagingTemplate.java:162)
> at org.springframework.messaging.simp.SimpMessagingTemplate.doSend(SimpMessagingTemplate.java:48)
> at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109)
> at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:151)
> at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:129)
> at org.springframework.messaging.core.AbstractMessageSendingTemplate.convertAndSend(AbstractMessageSendingTemplate.java:122)
> at org.apache.ambari.server.events.MessageEmitter.emitMessageToAll(MessageEmitter.java:159)
> at org.apache.ambari.server.events.DefaultMessageEmitter.emitMessage(DefaultMessageEmitter.java:102)
> at org.apache.ambari.server.events.listeners.requests.STOMPUpdateListener.onUpdateEvent(STOMPUpdateListener.java:53)
> at sun.reflect.GeneratedMethodAccessor174.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at com.google.common.eventbus.Subscriber.invokeSubscriberMethod(Subscriber.java:87)
> at com.google.common.eventbus.Subscriber$1.run(Subscriber.java:72)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> 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.messaging.simp.broker.SimpleBrokerMessageHandler.sendMessageToSubscribers(SimpleBrokerMessageHandler.java:388)
> at org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.handleMessageInternal(SimpleBrokerMessageHandler.java:304)
> at org.springframework.messaging.simp.broker.AbstractBrokerMessageHandler.handleMessage(AbstractBrokerMessageHandler.java:256)
> at org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask.run(ExecutorSubscribableChannel.java:144)
> ... 21 more
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)