Really appreciate your time Bobby . So the error I got when I added this line to drpc.childopts "-Xmx768m _JAAS_PLACEHOLDER -Xloggc:/var/log/storm/drpc-gc.log -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintGCDateStamps" I got Error: Could not find or load main class _JAAS_PLACEHOLDER how can I fix it ?
On Thursday, June 29, 2017, Bobby Evans <[email protected]> wrote: > 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 >> >>
