I don't see issues with your configs on the surface.
- Bobby On Thursday, June 29, 2017, 10:02:37 AM CDT, sam mohel <[email protected]> wrote: Are my configurations right ? I got in terminal when submitted the topology after some times drpcexecutionexception(msg:request timed out) In log file of drpc I got [INFO] Starting Distributed RPC servers... [WARN] Timeout DRPC request id: 200 start at 1498657923 In worker log file doesn't receive any error message . But I tried to add this drpc.childopts: "-Xmx768m _JAAS_PLACEHOLDER -Xloggc:/var/log/storm/drpc-gc.log -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintGCDateStamps" in storm.yaml to check if there is problem in RAM and retsart submitting again . I got in drpc terminal Error: Could not find or load main class _JAAS_PLACEHOLDER And in terminal when submitted Exception in thread "main" java.lang.RuntimeException: org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refused (Connection refused) at backtype.storm.utils.DRPCClient.<init>(DRPCClient.java:42) at backtype.storm.utils.DRPCClient.<init>(DRPCClient.java:47) at trident.FirstStoryDetection.main(FirstStoryDetection.java:308)Caused by: org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refused (Connection refused) On Thursday, June 29, 2017, Bobby Evans <[email protected]> wrote: > You are going to need to look at the logs for your topology and the logs for > the drpc server to see if there is anything in there that indicates what is > happening. > > > - Bobby > > > On Wednesday, June 28, 2017, 11:21:14 PM CDT, sam mohel <[email protected]> > wrote: > > I submitted topology in local without any problem , but in production mode i > couldn't as you can see in ui zeros values in columns except execute columns . > i got after sometimes in terminal drpcexecutionexception(msg: request timed > out) > my configurations are > Machine A and Machine B > storm.yaml in Machine A is > storm.zookeeper.servers: > - "192.168.x.x" > > nimbus.host : "192.168.x.x" > supervisor.childopts: "-Xmx4g" > worker.childopts: "-Xmx4g" > storm.yaml in Machine B is > storm.zookeeper.servers: > - "192.168.x.x" > > nimbus.host : "192.168.x.x" > supervisor.childopts: "-Xmx4g" > worker.childopts: "-Xmx4g" > i set drpc in the code > Config conf = new Config(); > List<String> dprcServers = new ArrayList<String>(); > dprcServers.add("192.168.x.x") ; > conf.put(Config.DRPC_SERVERS, dprcServers); > conf.put(Config.DRPC_PORT, 3772); > // distributed mode > Config conf = createTopologyConfiguration( prop, true); > LocalDRPC drpc = null; > StormSubmitter.submitTopology( args[0], conf, buildTopology(drpc)); > client=new DRPCClient("192.168.x.x", 3772); > i used same ip address for storm.zookeeper.servers , nimbus.host > ,dprcServers and DRPCClient . Is that wrong ? > and i ran nimbus , drpc,ui in Machine A , I ran supervisor in Machine B > i appreciate any help , Thanks > >
