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
>
>
