Hello to all,I am glad that other people face the same problem. I thought i was
making something wrong all this time. Typical DRPC topology examples give the
same error message to me as well. I set up the DRPC server running and i send a
message from another java app using DRPC client. My app never gets a response,
only the message
WARN o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR 2020ms (NOT
MAX)
Exception in thread "main" java.lang.RuntimeException:
java.lang.RuntimeException:
org.apache.storm.thrift.transport.TTransportException:
java.net.ConnectException: Connection refused: connect
at
org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:108)
at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:69)
at org.apache.storm.utils.DRPCClient.<init>(DRPCClient.java:44)
at org.apache.storm.utils.DRPCClient.<init>(DRPCClient.java:39)
at com.jrtechnologies.pciengine.clientsource.Source.main(Source.java:84)
The DRPC client gives a response only if i use DRPC client inside the topology
code... If i use postman to send http request, i also get the same error i the
DRPC server console.
I use storm 1.1.0 and i have used the default settings for DRPC server in
localmode.
Στις 4:54 μ.μ. Παρασκευή, 30 Ιουνίου 2017, ο/η Bobby Evans
<[email protected]> έγραψε:
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
outorg.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
