Hi Dhaval, We have tried with the below config but no luck . Anything else to add to it ?
Regards Sridhar Gadi -----Original Message----- From: Dhaval Modi [mailto:[email protected]] Sent: Tue 9/9/2014 9:45 AM To: user Cc: Pavan Jakati G Subject: Re: Running Topology on Remote Machine Hi Sridhar, Did you try commenting " conf.setMaxTaskParallelism(10);" ? Regards, Dhaval Modi [email protected] On 9 September 2014 09:13, Sridhar G <[email protected]> wrote: > > > > > Hi All, > > > > We are stuck with running our topology on Remote Machine. We have be able > to run our topology on local machine which emits tuples. But when we try to > run it on Remote Machine it does not emit tuples. Whereas the Formation of > Topology is shown on STORM UI under TOPOLOGY SUMMARY. TOPOLOGY STATS , > SPOUTS and BOLTS are visible with ZERO emits. > > > > The Code which we have used for Running Topology on REMOTE Machine is: > > > > LIBRARIES IMPORTS ARE - > > > > import backtype.storm.Config; > > import backtype.storm.LocalCluster; > > import backtype.storm.topology.TopologyBuilder; > > import backtype.storm.utils.Utils; > > > > > > import org.json.simple.JSONValue; > > import backtype.storm.StormSubmitter; > > import backtype.storm.generated.AlreadyAliveException; > > import backtype.storm.generated.Nimbus.Client; > > import backtype.storm.topology.TopologyBuilder; > > import backtype.storm.utils.NimbusClient; > > import java.util.Map; > > > ------------------------------------------------------------------------------------------------------------------------- > > *TOPOLOGY PROGRAM -* > > > > TopologyBuilder builder = new TopologyBuilder(); > > builder.setSpout("POCspout", new POCSpout(),3); > > builder.setBolt("POCbolt", new > POCBolt(),3).shuffleGrouping("POCspout"); > > > > Config conf = new Config(); > > conf.put(Config.NIMBUS_HOST, "192.xxx.xx.x"); > > conf.setDebug(true); > > conf.setNumWorkers(1); > > conf.setMaxSpoutPending(5000); > > conf.setNumAckers(1); > > conf.setMaxTaskParallelism(10); > > Map storm_conf = Utils.readStormConfig(); > > > > storm_conf.put("nimbus.host", "192.xxx.xx.x"); > > Client client = > NimbusClient.getConfiguredClient(storm_conf).getClient(); > > > > String inputJar = > "/root/SOIM_PaVan/target/SOIMTopology-1.0-SNAPSHOT.jar"; > > NimbusClient nimbus = new NimbusClient(storm_conf, > "192.xxx.xx.x",6627); > > String uploadedJarLocation = > StormSubmitter.submitJar(storm_conf,inputJar); > > > > try { > > String jsonConf = JSONValue.toJSONString(storm_conf); > > > > nimbus.getClient().submitTopology("TOPOLOGYPOC",uploadedJarLocation,jsonConf,builder.createTopology()); > > } > > catch (AlreadyAliveException ae) > > { > > ae.printStackTrace(); > > } > > > > > > > > *For any Correction in code let us know.* > > > > > > Regards, > > Sridhar > > *Believe in the impossible and remove the improbable* > > The information contained in this transmission may contain privileged and > confidential information of Microland Limited, including information > protected by privacy laws. It is intended only for the use of Microland > Limited. If you are not the intended recipient, you are hereby notified > that any review, dissemination, distribution, or duplication of this > communication is strictly prohibited. If you are not the intended > recipient, please contact the sender by reply email and destroy all copies > of the original message. > The information contained in this transmission may contain privileged and confidential information of Microland Limited, including information protected by privacy laws. It is intended only for the use of Microland Limited. If you are not the intended recipient, you are hereby notified that any review, dissemination, distribution, or duplication of this communication is strictly prohibited. If you are not the intended recipient, please contact the sender by reply email and destroy all copies of the original message.
