[FALCON-1491] Update ActiveMQ version to 5.12

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.7
• Fix Version/s: 0.8

Environment

All

• Assignee: Peeyush Bishnoi
• Reporter: Venkat Ranganathan
• Created: 25/Sep/15 20:40
• Updated: 06/Oct/15 22:10
• Resolved: 06/Oct/15 22:10

Description

Current we have activemq version set to 5.4.3. Some customers have reported issues something like below under load

2015-09-23 20:04:24,030 ERROR - [ActiveMQ Session Task:] ~ Unable to schedule late rerun for entity instance: PROCESS (itemdetails-delta-stage-process): 2015-09-24T00:30Z And WorkflowId: 0152700-150904115755184-oozie-oozi-W (LateRerunHandler:94)
org.apache.falcon.FalconException: Unable to offer event:clusterName=primary-cluster*wfId=0152700-150904115755184-oozie-oozi-W*msgInsertTime=1443054600000*delayInMilliSec=2100000*entityType=PROCESS*entityName=itemdetails-delta-stage-process*instance=2015-09-24T00:30Z*runId=0*workflowUser=bdp0002p01 to ActiveMQ
at org.apache.falcon.rerun.queue.ActiveMQueue.offer(ActiveMQueue.java:65)
at org.apache.falcon.rerun.handler.AbstractRerunHandler.offerToQueue(AbstractRerunHandler.java:62)
at org.apache.falcon.rerun.handler.LateRerunHandler.handleRerun(LateRerunHandler.java:92)
at org.apache.falcon.rerun.handler.LateRerunHandler.onSuccess(LateRerunHandler.java:219)
at org.apache.falcon.workflow.WorkflowJobEndNotificationService.notifySuccess(WorkflowJobEndNotificationService.java:101)
at org.apache.falcon.messaging.JMSMessageConsumer.onSuccess(JMSMessageConsumer.java:137)
at org.apache.falcon.messaging.JMSMessageConsumer.onMessage(JMSMessageConsumer.java:109)
at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1229)
at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:134)
at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:205)
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
Caused by: javax.jms.JMSException: PageFile is not loaded
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1287)
at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1760)
at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:231)
at org.apache.activemq.ActiveMQMessageProducerSupport.send(ActiveMQMessageProducerSupport.java:241)
at org.apache.falcon.rerun.queue.ActiveMQueue.offer(ActiveMQueue.java:59)
... 14 more
Caused by: java.lang.IllegalStateException: PageFile is not loaded
at org.apache.kahadb.page.PageFile.assertLoaded(PageFile.java:721)
at org.apache.kahadb.page.PageFile.tx(PageFile.java:239)
at org.apache.activemq.broker.scheduler.JobSchedulerImpl.schedule(JobSchedulerImpl.java:110)
at org.apache.activemq.broker.scheduler.SchedulerBroker.send(SchedulerBroker.java:185)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:227)
at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:462)
at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:677)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:311)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:228)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202) ]

This has been fixed in 5.6.0 it looks like by ActiveMQ, but it would be good to update to 5.12

Issue Links

• links to: Review Board Link