Return-Path: X-Original-To: apmail-uima-user-archive@www.apache.org Delivered-To: apmail-uima-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 871487705 for ; Thu, 1 Dec 2011 05:26:52 +0000 (UTC) Received: (qmail 8508 invoked by uid 500); 1 Dec 2011 05:26:51 -0000 Delivered-To: apmail-uima-user-archive@uima.apache.org Received: (qmail 8244 invoked by uid 500); 1 Dec 2011 05:26:50 -0000 Mailing-List: contact user-help@uima.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@uima.apache.org Delivered-To: mailing list user@uima.apache.org Received: (qmail 8232 invoked by uid 99); 1 Dec 2011 05:26:47 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Dec 2011 05:26:47 +0000 X-ASF-Spam-Status: No, hits=0.3 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_SOFTFAIL X-Spam-Check-By: apache.org Received-SPF: softfail (athena.apache.org: transitioning domain of meghana.marathe@germinait.com does not designate 209.85.214.47 as permitted sender) Received: from [209.85.214.47] (HELO mail-bw0-f47.google.com) (209.85.214.47) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 01 Dec 2011 05:26:41 +0000 Received: by bkbzv15 with SMTP id zv15so1207915bkb.6 for ; Wed, 30 Nov 2011 21:26:20 -0800 (PST) Received: by 10.205.143.18 with SMTP id jk18mr5586151bkc.1.1322717179766; Wed, 30 Nov 2011 21:26:19 -0800 (PST) MIME-Version: 1.0 Received: by 10.223.73.203 with HTTP; Wed, 30 Nov 2011 21:25:58 -0800 (PST) In-Reply-To: References: From: Meghana Date: Thu, 1 Dec 2011 10:55:58 +0530 Message-ID: Subject: Re: UIMA AS: Lost Connection to Broker To: user@uima.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hi Jerry, After last night's run, the ActiveMQ broker has consumed barely 50-60MB of RAM (in JConsole), whereas the AS has used all of its allocated RAM (2GB). If I only restart the AS (not the broker), it works just fine! Thanks, ..meghana On 30 November 2011 20:28, Meghana wrote: > Hi Jerry, > > Yeah, its the default 256M, will try increasing it. The strange thing > is, restarting the broker makes no difference; the AS remains > unresponsive. However, if i also restart the AS, then things flow as > normal. > > Could this be because i'm using a 2.4.0 snapshot build instead of a > stable release? > > Thanks, > > ..meghana > > > > On 30 November 2011 20:08, Jaroslaw Cwiklik wrote: >> Meghana, what is your broker's -Xmx setting? On linux, >> grep ACTIVEMQ_HOME/bin/activemq for ACTIVEMQ_OPTS_MEMORY. If you are >> running with a default setting (256M) perhaps you need to increase the >> memory. >> >> Jerry >> >> On Mon, Nov 28, 2011 at 11:55 PM, Meghana wrote: >> >>> Hi, >>> >>> I have an aggregate AE deployed as an AS with a remote primitive. Both >>> have their queues at the same broker. Clients send requests to the >>> aggregate using the sendCAS() method. We use the default 5.4.1 >>> ActiveMQ version and configuration distributed with UIMA AS. The AS's >>> CAS pool size is 2, and so is the client's. >>> >>> After working fine for ~10 hours, the AS listener received 25 >>> exceptions of the following form from its collocated delegates: >>> 2011-11-29 01:54:55,124 ERROR as.AsListener: >>> org.apache.uima.aae.error.UimaAsDelegateException: ----> >>> Controller:/AnalysisAggregator Received Exception =A0on >>> CAS:61b4719b:133ebbc4eb3:-7fd9 From Delegate:APAnnotator : >>> org.apache.uima.adapter.jms.activemq.JmsOutputChannel : 870 >>> >>> Then, the AS started returning all CASes with status failed, with the >>> following logs: >>> Nov 29, 2011 2:41:25 AM org.apache.uima.aae.delegate.Delegate$1 >>> Delegate.TimerTask.run >>> WARNING: Timeout While Waiting For Reply From Delegate:q_async_ae >>> Process CAS Request Timed Out. Configured Reply Window Of 1,200,000. >>> Cas Reference Id:-3c5bfde0:133ebe967b3:-7fe6 >>> Nov 29, 2011 2:41:25 AM >>> org.apache.uima.adapter.jms.client.ClientServiceDelegate handleError >>> WARNING: Process Timeout - Uima AS Client Didn't Receive Process Reply >>> Within Configured Window Of:1,200,000 millis >>> Nov 29, 2011 2:41:25 AM >>> org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_imp= l >>> notifyOnTimout >>> WARNING: Request To Process Cas Has Timed-out. =A0Service >>> Queue:q_async_ae. Cas Timed-out on host: 192.168.0.121 >>> Nov 29, 2011 2:41:25 AM >>> org.apache.uima.adapter.jms.client.ActiveMQMessageSender run >>> INFO: UIMA AS Client Message Dispatcher Sending GetMeta Ping To the Ser= vice >>> Nov 29, 2011 2:41:25 AM >>> org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_imp= l >>> sendCAS >>> INFO: Uima AS Client Sent PING Message To Service: q_async_ae >>> Nov 29, 2011 2:41:25 AM >>> org.apache.uima.adapter.jms.client.BaseUIMAAsynchronousEngineCommon_imp= l >>> handleException >>> INFO: Received Exception In Message From:UimaASClient Cas >>> Identifier:-3c5bfde0:133ebe967b3:-7fe3 >>> Exception:org.apache.uima.jms.error.handler.BrokerConnectionException: >>> Unable To Deliver CAS:-3c5bfde0:133ebe967b3:-7fe3 To Destination. >>> Connection To Broker tcp://broker_url:61616 Has Been Lost >>> >>> The remote delegate hasn't logged any errors, and the broker "seems" >>> to be up, but it has a few of these in its log: >>> 2011-11-29 02:13:33,279 [168.0.121:49414] INFO =A0Transport =A0- Transp= ort >>> failed: java.net.SocketException: Connection reset >>> java.net.SocketException: Connection reset >>> =A0 =A0 =A0 =A0at java.net.SocketInputStream.read(SocketInputStream.jav= a:168) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuffer= edInputStream.java:50) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java= :575) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuffer= edInputStream.java:58) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java= :560) >>> =A0 =A0 =A0 =A0at java.io.DataInputStream.readInt(DataInputStream.java:= 370) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.ja= va:269) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport= .java:226) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:= 218) >>> =A0 =A0 =A0 =A0at >>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:20= 1) >>> =A0 =A0 =A0 =A0at java.lang.Thread.run(Thread.java:619) >>> >>> What could be the problem here? Should i update the ActiveMQ distro? >>> They have retracted the 5.4.1 release due to the bug at >>> https://issues.apache.org/jira/browse/AMQ-3491 and recommend using >>> 5.4.3 instead. >>> >>> Thanks a lot, >>> >>> ..meghana >>> >> >