uima-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "reshu.agarwal" <reshu.agar...@orkash.com>
Subject Re: problem if use remoteAnalysisEngine in deployment script
Date Tue, 16 Jul 2013 09:23:52 GMT
Hi,

I tried deploying the services with the other example which uses the 
flowcontrollerand the services starts but with these errors:

Deployment xml:

   <deployment protocol="jms" provider="activemq">
     <casPool numberOfCASes="20"/>
     <service>
       <inputQueue endpoint="CorefDetectorTaeFixedQueue" 
brokerURL="tcp://localhost:61616"  prefetch="0"/>
       <topDescriptor>
         <import 
location="../../desc//flow_controller/CorefDetectorTAE_AdvancedFixedFlow1.xml"/> 

       </topDescriptor>
     <analysisEngine async="true">
         <scaleout numberOfInstances="1"/>
         <delegates>
           <remoteAnalysisEngine key="StemmerDescriptor">
             <inputQueue endpoint="StemmerDescriptorQueue" 
brokerURL="tcp://localhost:61616"/>
             <serializer method="xmi"/>
         <asyncAggregateErrorConfiguration>
         <getMetadataErrors
           maxRetries="0"
           timeout="100000"
           errorAction="disable"/>
                  <processCasErrors maxRetries="0" timeout="100000" 
continueOnRetryFailure="false" thresholdCount="100" 
thresholdWindow="1000" thresholdAction="disable"/>
                 </asyncAggregateErrorConfiguration>
           </remoteAnalysisEngine>
       <remoteAnalysisEngine key="StopwordsDescriptor" >
             <inputQueue endpoint="StopwordsDescriptorQueue" 
brokerURL="tcp://1localhost:61616"/>
             <serializer method="xmi"/>
         <asyncAggregateErrorConfiguration>
         <getMetadataErrors
           maxRetries="0"
           timeout="100000"
           errorAction="disable"/>
                  <processCasErrors maxRetries="0" timeout="100000" 
continueOnRetryFailure="false" thresholdCount="100" 
thresholdWindow="1000" thresholdAction="disable"/>
                 </asyncAggregateErrorConfiguration>
           </remoteAnalysisEngine>
         </delegates>
       </analysisEngine>
  </service>
   </deployment>

Flow Controller contains flow:

             <string>OpenNLPSentenceDetector</string>
             <string>OpenNLPTokenizer</string>
             <string>OpenNLPPOSTagger</string>
<string>StemmerDescriptor,StopwordsDescriptor</string>
             <string>TreeBankChunkerDescriptor</string>

deployment output: /bin/deployAsyncService.sh 
UIMA_AS/deploy/as/Deploy_CorefDetectorTAE_Fixed1.xml

Service:TreeBankChunkerDescriptor Initialized. Ready To Process Messages 
>From Queue:inQ_TreeBankChunkerDescriptor_1.1
Service:OpenNLPSentenceDetector Initialized. Ready To Process Messages 
 From Queue:inQ_OpenNLPSentenceDetector_1.2
Service:OpenNLPTokenizer Initialized. Ready To Process Messages From 
Queue:inQ_OpenNLPTokenizer_1.3
Service:OpenNLPPOSTagger Initialized. Ready To Process Messages From 
Queue:inQ_OpenNLPPOSTagger_1.5
Could not refresh JMS Connection for destination 
'temp-queue://ID:.....-56497-1373965746367-0:1:1' - silently retrying in 
5 ms. Cause: java.io.InterruptedIOException
Could not refresh JMS Connection for destination 
'temp-queue://ID:.....-56497-1373965746367-0:0:1' - silently retrying in 
5 ms. Cause: java.io.InterruptedIOException
Could not stop service: tcp:///localhost:61616. Reason: 
java.lang.InterruptedException
java.lang.InterruptedException
     at 
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1325)
     at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:282)
     at 
org.apache.activemq.transport.tcp.TcpTransport.doStop(TcpTransport.java:531)
     at org.apache.activemq.util.ServiceSupport.stop(ServiceSupport.java:69)
     at 
org.apache.activemq.transport.tcp.TcpTransport.stop(TcpTransport.java:548)
     at 
org.apache.activemq.transport.InactivityMonitor.stop(InactivityMonitor.java:133)
     at 
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
     at 
org.apache.activemq.transport.WireFormatNegotiator.stop(WireFormatNegotiator.java:91)
     at 
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
     at 
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
     at 
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)
     at 
org.apache.activemq.util.ServiceSupport.dispose(ServiceSupport.java:43)
     at 
org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:656)
     at 
org.springframework.jms.connection.ConnectionFactoryUtils.releaseConnection(ConnectionFactoryUtils.java:80)
     at 
org.springframework.jms.listener.AbstractJmsListeningContainer.refreshSharedConnection(AbstractJmsListeningContainer.java:385)
     at 
org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer.refreshConnectionUntilSuccessful(UimaDefaultMessageListenerContainer.java:149)
     at 
org.springframework.jms.listener.DefaultMessageListenerContainer.recoverAfterListenerSetupFailure(DefaultMessageListenerContainer.java:838)
     at 
org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer.recoverAfterListenerSetupFailure(UimaDefaultMessageListenerContainer.java:174)
     at 
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:969)
     at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
     at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
     at 
org.apache.uima.aae.UimaAsThreadFactory$1.run(UimaAsThreadFactory.java:118)
     at java.lang.Thread.run(Thread.java:722)
Could not stop service: tcp:///localhost:61616. Reason: 
java.lang.InterruptedException
java.lang.InterruptedException
     at 
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1325)
     at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:282)
     at 
org.apache.activemq.transport.tcp.TcpTransport.doStop(TcpTransport.java:531)
     at org.apache.activemq.util.ServiceSupport.stop(ServiceSupport.java:69)
     at 
org.apache.activemq.transport.tcp.TcpTransport.stop(TcpTransport.java:548)
     at 
org.apache.activemq.transport.InactivityMonitor.stop(InactivityMonitor.java:133)
     at 
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
     at 
org.apache.activemq.transport.WireFormatNegotiator.stop(WireFormatNegotiator.java:91)
     at 
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
     at 
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
     at 
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)
     at 
org.apache.activemq.util.ServiceSupport.dispose(ServiceSupport.java:43)
     at 
org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:656)
     at 
org.springframework.jms.connection.ConnectionFactoryUtils.releaseConnection(ConnectionFactoryUtils.java:80)
     at 
org.springframework.jms.listener.AbstractJmsListeningContainer.refreshSharedConnection(AbstractJmsListeningContainer.java:385)
     at 
org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer.refreshConnectionUntilSuccessful(UimaDefaultMessageListenerContainer.java:149)
     at 
org.springframework.jms.listener.DefaultMessageListenerContainer.recoverAfterListenerSetupFailure(DefaultMessageListenerContainer.java:838)
     at 
org.apache.uima.adapter.jms.activemq.UimaDefaultMessageListenerContainer.recoverAfterListenerSetupFailure(UimaDefaultMessageListenerContainer.java:174)
     at 
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:969)
     at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
     at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
     at 
org.apache.uima.aae.UimaAsThreadFactory$1.run(UimaAsThreadFactory.java:118)
     at java.lang.Thread.run(Thread.java:722)
All scheduled consumers have been paused, probably due to tasks having 
been rejected. Check your thread pool configuration! Manual recovery 
necessary through a start() call.
All scheduled consumers have been paused, probably due to tasks having 
been rejected. Check your thread pool configuration! Manual recovery 
necessary through a start() call.
Service:Coref Detector TAE with Advanced Fixed Flow Controller 
Initialized. Ready To Process Messages From Queue:CorefDetectorTaeFixedQueue

-- 
Thanks and Regards,
Reshu Agarwal


Mime
View raw message