Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.7
-
None
-
None
-
All
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
Attachments
Attachments
Issue Links
- links to