[jira] [Commented] (FALCON-1491) Update ActiveMQ version to 5.12

["Peeyush Bishnoi (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FALCON-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14910148#comment-14910148 ] 

Peeyush Bishnoi commented on FALCON-1491:
-----------------------------------------

As [~venkatnrangan] mentioned we need to update the activemq version to 5.12.0 to resolve this issue and for this we require activemq-all and activemq-kahadb-store which is available in version 5.12.0. I will provide the patch for this.

> Update ActiveMQ version to 5.12
> -------------------------------
>
>                 Key: FALCON-1491
>                 URL: https://issues.apache.org/jira/browse/FALCON-1491
>             Project: Falcon
>          Issue Type: Bug
>    Affects Versions: 0.7
>         Environment: All
>            Reporter: Venkat Ranganathan
>            Assignee: Peeyush Bishnoi
>             Fix For: 0.8
>
>
> Current we have activemq version set to 5.4.3.   Some customers have reported issues something like below under load
> {noformat}
> 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) ]
> {noformat}
> This has been fixed in 5.6.0 it looks like by ActiveMQ, but it would be good to update to 5.12 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)