Description
Exception listed below is seen in falcon.applicaiton.log when Falcon service is stopped.
falcon.metric.log:
2014-09-12 06:58:09,963 {Action:rerun-queue-failed, Dimensions:
{message=Error while reading message from the queue: , exception=org.apache.falcon.FalconException: Error getting the message from ActiveMQ: }, Status: SUCCEEDED, Time-taken:23434 ns}
2014-09-12 06:54:57,528 INFO - [ActiveMQ ShutdownHook:] ~ ActiveMQ Message Broker (localhost, ID:cluster-securefalcon-3-58161-1410502679569-0:1) is shutting down (BrokerService:560) 2014-09-12 06:54:57,537 INFO - [ActiveMQ ShutdownHook:] ~ Connector vm://localhost Stopped (TransportConnector:288) 2014-09-12 06:54:58,229 INFO - [ActiveMQ Connection Executor: tcp://cluster-securefalcon-3.cs1cloud.internal/172.18.145.111:61616:] ~ Error in onException for subscriber of topic: FALCON.ENTITY.TOPIC (JMSMessageConsumer:132) javax.jms.JMSException: java.io.EOFException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) at org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1833) at org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1850) at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:101) at org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:126) at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:101) at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:101) at org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:160) at org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:266) at org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:96) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:206) at java.lang.Thread.run(Thread.java:662) Caused by: java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:375) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202) ... 1 more 2014-09-12 06:54:58,251 ERROR - [LaterunHandler:] ~ Error getting the message from ActiveMQ (DelayedQueue:88) javax.jms.JMSException: java.io.EOFException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:458) at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:504) at org.apache.falcon.rerun.queue.ActiveMQueue.take(ActiveMQueue.java:81) at org.apache.falcon.rerun.handler.AbstractRerunHandler.takeFromQueue(AbstractRerunHandler.java:66) at org.apache.falcon.rerun.handler.AbstractRerunConsumer.run(AbstractRerunConsumer.java:57) at java.lang.Thread.run(Thread.java:662) Caused by: java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:375) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202) ... 1 more 2014-09-12 06:54:58,253 ERROR - [LaterunHandler:] ~ Error while reading message from the queue (AbstractRerunConsumer:60) org.apache.falcon.FalconException: Error getting the message from ActiveMQ: at org.apache.falcon.rerun.queue.ActiveMQueue.take(ActiveMQueue.java:89) at org.apache.falcon.rerun.handler.AbstractRerunHandler.takeFromQueue(AbstractRerunHandler.java:66) at org.apache.falcon.rerun.handler.AbstractRerunConsumer.run(AbstractRerunConsumer.java:57) at java.lang.Thread.run(Thread.java:662) Caused by: javax.jms.JMSException: java.io.EOFException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:458) at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:504) at org.apache.falcon.rerun.queue.ActiveMQueue.take(ActiveMQueue.java:81) ... 3 more Caused by: java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:375) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)