Hi Jerry, Thanks a lot!
..meghana On 7 October 2011 22:54, Jaroslaw Cwiklik <[email protected]> wrote: > Meghana, created a JIRA https://issues.apache.org/jira/browse/UIMA-2251 to > document this. Not yet sure what the problem is. > > On Tue, Oct 4, 2011 at 3:52 AM, Meghana <[email protected]>wrote: > >> Hi, >> >> I have an aggregate AE with a remote primitive (OntoAnnotator). Both have >> their queues at the same broker. Clients send requests to the aggregate >> using the sendCAS() method. >> >> This was running fine for about 5-6 hours, but then the aggregate logged an >> error: >> 11/10/04 02:00:12 INFO cpe.DynamicFlowController$DynamicFlow: Next >> Executing >> Annotator :: OntoAnnotator >> 11/10/04 02:00:12 INFO activemq.JmsOutputChannel: Controller >> AnalysisAggregator Invalidating JMS Connection To Broker >> tcp://broker_ip:61616 and Closing Sessions To Delegates >> >> It had received 4-5 timeouts from the remote delegate over time, but at >> least a couple of hours before the above log. Both the broker and the >> remote >> delegate were still running and had not crashed. >> >> The aggregate continued processing requests after that -- the CASes are >> processed by all collocated primitives but not the remote one. Each CAS >> process request gets an exception: >> 11/10/04 02:00:12 WARN >> activemq.JmsEndpointConnection_impl: >> org.apache.uima.aae.error.DelegateConnectionLostException: >> Controller:AnalysisAggregator Lost Connection to Delegate:OntoAnnotator >> at >> >> org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl.send(JmsEndpointConnection_impl.java:547) >> at >> >> org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl.send(JmsEndpointConnection_impl.java:509) >> at >> >> org.apache.uima.adapter.jms.activemq.JmsOutputChannel.dispatch(JmsOutputChannel.java:1366) >> at >> >> org.apache.uima.adapter.jms.activemq.JmsOutputChannel.sendCasToRemoteEndpoint(JmsOutputChannel.java:1527) >> at >> >> org.apache.uima.adapter.jms.activemq.JmsOutputChannel.serializeCasAndSend(JmsOutputChannel.java:658) >> at >> >> org.apache.uima.adapter.jms.activemq.JmsOutputChannel.sendRequest(JmsOutputChannel.java:610) >> at >> >> org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl.dispatch(AggregateAnalysisEngineController_impl.java:2395) >> at >> >> org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl.dispatchProcessRequest(AggregateAnalysisEngineController_impl.java:2435) >> at >> >> org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl.simpleStep(AggregateAnalysisEngineController_impl.java:1295) >> at >> >> org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl.executeFlowStep(AggregateAnalysisEngineController_impl.java:2316) >> at >> >> org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl.process(AggregateAnalysisEngineController_impl.java:1230) >> at >> org.apache.uima.aae.handler.HandlerBase.invokeProcess(HandlerBase.java:118) >> at >> >> org.apache.uima.aae.handler.input.ProcessResponseHandler.cancelTimerAndProcess(ProcessResponseHandler.java:108) >> >> When I tried stopping the aggregate, the logs said the following though >> there was no CAS request in process: >> 11/10/04 10:18:18 WARN service.UIMA_Service: Uima AS Service >> AnalysisAggregator Caught Kill Signal - Initiating Quiesce and Stop >> 11/10/04 10:18:18 INFO controller.BaseAnalysisEngineController: Stopping >> Controller: AnalysisAggregator >> 11/10/04 10:18:18 INFO activemq.JmsInputChannel: Stopping Service JMS >> Transport. Service: q_async_ae >> 11/10/04 10:18:18 INFO activemq.JmsInputChannel: Controller: >> AnalysisAggregator Stopped Listener on Endpoint: queue://q_async_ae >> Selector: Selector:Command=2000 OR Command=2002. >> 11/10/04 10:18:18 INFO activemq.JmsInputChannel: Stopping Service JMS >> Transport. Service: q_async_ae >> 11/10/04 10:18:18 INFO activemq.JmsInputChannel: Controller: >> AnalysisAggregator Stopped Listener on Endpoint: queue://q_async_ae >> Selector: Selector:Command=2001. >> 11/10/04 10:18:18 INFO controller.BaseAnalysisEngineController: Controller: >> AnalysisAggregator Registering onEmpty Callback With InProcessCache. >> 11/10/04 10:18:18 INFO controller.BaseAnalysisEngineController: Controller: >> AnalysisAggregator Awaiting onEmpty Callback From InProcessCache >> >> After restarting just the aggregate, it connected to the remote AE just >> fine. So i'm wondering why the aggregate decided to stop communicating with >> it earlier? >> >> I've seen a previous thread with a similar error ( >> http://thread.gmane.org/gmane.comp.apache.uima.general/3351/focus=3388), >> but >> there the broker was wilfully taken down, whereas I did no such thing. >> >> Thanks, and sorry for the barrage of info. >> >> Meghana >> >
