Return-Path: X-Original-To: apmail-zookeeper-user-archive@www.apache.org Delivered-To: apmail-zookeeper-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 E4AF6F17A for ; Wed, 20 Mar 2013 22:57:07 +0000 (UTC) Received: (qmail 16527 invoked by uid 500); 20 Mar 2013 22:57:07 -0000 Delivered-To: apmail-zookeeper-user-archive@zookeeper.apache.org Received: (qmail 16503 invoked by uid 500); 20 Mar 2013 22:57:07 -0000 Mailing-List: contact user-help@zookeeper.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@zookeeper.apache.org Delivered-To: mailing list user@zookeeper.apache.org Received: (qmail 16494 invoked by uid 99); 20 Mar 2013 22:57:07 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 20 Mar 2013 22:57:07 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of rsiemens@greatergood.com designates 206.253.208.224 as permitted sender) Received: from [206.253.208.224] (HELO mail.yss4.com) (206.253.208.224) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 20 Mar 2013 22:57:00 +0000 From: Ron Siemens Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable Subject: Norbert Client/Server ExecutionException Message-Id: Date: Wed, 20 Mar 2013 15:56:38 -0700 To: user@zookeeper.apache.org Mime-Version: 1.0 (Mac OS X Mail 6.3 \(1503\)) X-Mailer: Apple Mail (2.1503) X-Virus-Checked: Checked by ClamAV on apache.org I couldn't find a mail list for Norbert, perhaps users are also here? I have been testing a NettyNetworkClient / NettyNetworkServer set up. I = have 10 threads configured for the receiver. I notice when I send out = many more requests, the client doesn't seem to block, so I'm wondering = where these extra requests are queued or what happens with them? In general, it is working as expected with up to around 40 or 50 calls = sent immediately sequentially. But with more, I am getting the below = execution when I try to access the results with the Future's get(). = There's no exceptions in the remote application service call, so I'm = assuming Norbert is generating it. I don't know why. Is the client = perhaps expected to throttle on its own? Ron java.util.concurrent.ExecutionException: = com.linkedin.norbert.network.netty.ClientChannelHandler$$anon$1: The = remote end threw an exception [order]:=20 at = com.linkedin.norbert.network.common.ResponseHelper$$anonfun$translateRespo= nse$1.apply(NorbertFuture.scala:201) at = com.linkedin.norbert.network.common.ResponseHelper$$anonfun$translateRespo= nse$1.apply(NorbertFuture.scala:201) at scala.Either.fold(Either.scala:95) at = com.linkedin.norbert.network.common.ResponseHelper$class.translateResponse= (NorbertFuture.scala:201) at = com.linkedin.norbert.network.common.FutureAdapter.translateResponse(Norber= tFuture.scala:32) at = com.linkedin.norbert.network.common.FutureAdapter.get(NorbertFuture.scala:= 49) at = com.charityusa.publisher.GraphPublisher.loadPrevOrders(GraphPublisher.java= :788) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 57) at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at sun.reflect.misc.Trampoline.invoke(MethodUtil.java:55) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 57) at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at sun.reflect.misc.MethodUtil.invoke(MethodUtil.java:263) at = javax.management.modelmbean.RequiredModelMBean.invokeMethod(RequiredModelM= Bean.java:1185) at = javax.management.modelmbean.RequiredModelMBean.invoke(RequiredModelMBean.j= ava:1049) at = org.springframework.jmx.export.SpringModelMBean.invoke(SpringModelMBean.ja= va:90) at = com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanS= erverInterceptor.java:819) at = com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:791) at = javax.management.remote.rmi.RMIConnectionImpl.doOperation(RMIConnectionImp= l.java:1447) at = javax.management.remote.rmi.RMIConnectionImpl.access$200(RMIConnectionImpl= .java:89) at = javax.management.remote.rmi.RMIConnectionImpl$PrivilegedOperation.run(RMIC= onnectionImpl.java:1292) at = javax.management.remote.rmi.RMIConnectionImpl.doPrivilegedOperation(RMICon= nectionImpl.java:1380) at = javax.management.remote.rmi.RMIConnectionImpl.invoke(RMIConnectionImpl.jav= a:812) at sun.reflect.GeneratedMethodAccessor76.invoke(Unknown Source) at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at = sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:322) at sun.rmi.transport.Transport$1.run(Transport.java:177) at sun.rmi.transport.Transport$1.run(Transport.java:174) at java.security.AccessController.doPrivileged(Native Method) at sun.rmi.transport.Transport.serviceCall(Transport.java:173) at = sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:553) at = sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.jav= a:808) at = sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java= :667) at = java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:= 1110) at = java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java= :603) at java.lang.Thread.run(Thread.java:722) Caused by: = com.linkedin.norbert.network.netty.ClientChannelHandler$$anon$1: The = remote end threw an exception [order]:=20 at = com.linkedin.norbert.network.netty.ClientChannelHandler.processException$1= (ClientChannelHandler.scala:140) at = com.linkedin.norbert.network.netty.ClientChannelHandler.messageReceived(Cl= ientChannelHandler.scala:135) at = org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelH= andler.java:100) at = org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannel= Pipeline.java:545) at = org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContex= t.sendUpstream(DefaultChannelPipeline.java:754) at = org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302) at = org.jboss.netty.handler.codec.oneone.OneToOneDecoder.handleUpstream(OneToO= neDecoder.java:76) at = org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannel= Pipeline.java:545) at = org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContex= t.sendUpstream(DefaultChannelPipeline.java:754) at = org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:302) at = org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageRecei= ved(FrameDecoder.java:317) at = org.jboss.netty.handler.codec.frame.FrameDecoder.callDecode(FrameDecoder.j= ava:299) at = org.jboss.netty.handler.codec.frame.FrameDecoder.messageReceived(FrameDeco= der.java:216) at = org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(Simple= ChannelUpstreamHandler.java:80) at = org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannel= Pipeline.java:545) at = org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContex= t.sendUpstream(DefaultChannelPipeline.java:754) at = org.jboss.netty.handler.logging.LoggingHandler.handleUpstream(LoggingHandl= er.java:231) at = org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannel= Pipeline.java:545) at = org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannel= Pipeline.java:540) at = org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274) at = org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261) at = org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:349) at = org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker= .java:280) at = org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200) at = org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.jav= a:108) at = org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorke= r.java:44) ... 3 more