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
