I'm facing problem with drpc . Here is my error xception in thread "main" DRPCExecutionException(msg:Request timed out) at backtype.storm.generated.DistributedRPC$execute_result.read(DistributedRPC.java:904) at org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:78) at backtype.storm.generated.DistributedRPC$Client.recv_execute(DistributedRPC.java:92) at backtype.storm.generated.DistributedRPC$Client.execute(DistributedRPC.java:78) at backtype.storm.utils.DRPCClient.execute(DRPCClient.java:71)
I hope can someone help On Friday, June 30, 2017, Bobby Evans <[email protected]> wrote: > If the topology is using LocalDRPC only things within the same process can access it. Your topology will not even attempt to communicate with the running DRPC server. LocalDRPC is intended for unit tests and the like. If you don't use LocalDRPC then your spouts should be able to connect to the running drpc server. > > - Bobby > > > On Friday, June 30, 2017, 10:24:30 AM CDT, J.R. Pauley <[email protected]> wrote: > > Bobby > Nothing in drpc.logs other than many timeouts > [WARN] Timeout DRPC request id: 1 start at 1498823858 > > As to topology it is running LOCALLY. Not sure if that is any issue > LocalCluster cluster = new LocalCluster(); > LocalDRPC drpc = new LocalDRPC(); > cluster.submitTopology("state_drpc", conf, basicStateAndDRPC(drpc, testSpout)); > I should mention my storm.yaml specifies zookeeper, nimbus, and drpc server all are 127.0.0.1 and I am trying to connect my DRPCClient also running on same box. > I am deploying both the local topology and the client via storm jar > One thing diff to me about this local topology is when it gets to end of main it neither quits nor sleeps, so I was assuming I could connect client at that point. Maybe not so?? > From LOGS 1 error: > INFO org.apache.storm.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) > > Hope that adds some useful info. > Thank You very much, > Jim > > > On Fri, Jun 30, 2017 at 9:53 AM, Bobby Evans <[email protected]> wrote: > > Do you have your topology running? The read timeout indicates that you successfully sent a message to the DRPC server, but no response was returned before the socket got a read timeout. This typically means that the topology was not running or was not able to talk to the DRPC server. Please check for errors in the topology logs and the DRPC server logs if the topology is up and running. > > > - Bobby > > > On Friday, June 30, 2017, 6:27:18 AM CDT, J.R. Pauley <[email protected]> wrote: > > Hello All: > I'm trying to get running an example from trident tutorial (Part04_BasicStateAndDRPC) and I can submit and run the main class but also have built a DRPCClient and trying to run that client on same box. I have my DRPC server running and listening on 3772 but all I can see from the client is a timeout. I have reverted my install to 0.9.6 to more closely match that of the tutorial but not sure what to look for at this point. > Has anyone experience with drpc client? > Exception: java.net. SocketTimeoutException: Read timed out > org.apache.thrift7.transport. TTransportException: java.net. SocketTimeoutException: Read timed out > at org.apache.thrift7.transport. TIOStreamTransport.read( TIOStreamTransport.java:129) > at org.apache.thrift7.transport. TTransport.readAll(TTransport. java:84) > at org.apache.thrift7.transport. TFramedTransport.readFrame( TFramedTransport.java:129) > at org.apache.thrift7.transport. TFramedTransport.read( TFramedTransport.java:101) > at org.apache.thrift7.transport. TTransport.readAll(TTransport. java:84) > at org.apache.thrift7.protocol. TBinaryProtocol.readAll( TBinaryProtocol.java:378) > at org.apache.thrift7.protocol. TBinaryProtocol.readI32( TBinaryProtocol.java:297) > at org.apache.thrift7.protocol. TBinaryProtocol. readMessageBegin( TBinaryProtocol.java:204) > at org.apache.thrift7. TServiceClient.receiveBase( TServiceClient.java:69) > at backtype.storm.generated. DistributedRPC$Client.recv_ execute(DistributedRPC.java: 92) > at backtype.storm.generated. DistributedRPC$Client.execute( DistributedRPC.java:78) > at backtype.storm.utils. DRPCClient.execute(DRPCClient. java:71) > at storm.trident.DrpcTestClient. main(DrpcTestClient.java:39) > Caused by: java.net. SocketTimeoutException: Read timed out > >
