Re: What is localNimbus?
LocalNimbus is something that is not really used. It provides a way for the StormSubmitter to be used when submitting a topology to a local mode cluster. No one uses it and in the past it didn't work, not sure if it works now or not. It is probably best to just not use it unless you really need to abstract out local mode from the topology code used to submit a topology. - Bobby On Tuesday, April 14, 2015 11:10 AM, Matthias J. Sax mj...@informatik.hu-berlin.de wrote: Dear all, I have a question about StormSubmitter class. It offers a method called setLocalNimbus(Nimbus.Iface localNimbusHandler). It sets the variable localNimbus and localNimbus is used within submitStormTopology. Can you explain what localNimbus is? As far as I understand Storm, there are two modes of operation: local and cluster. For local, a LocalCluster is used the emulates a cluster. In the cluster case, FlinkClient (or StormSubmitter that used FlinkClient internally) is used to submit a topology to a (remotely) running Nimbus. However, I cannot make sense out of a localNimbus. Thanks for you help. -Matthias
What is localNimbus?
Dear all, I have a question about StormSubmitter class. It offers a method called setLocalNimbus(Nimbus.Iface localNimbusHandler). It sets the variable localNimbus and localNimbus is used within submitStormTopology. Can you explain what localNimbus is? As far as I understand Storm, there are two modes of operation: local and cluster. For local, a LocalCluster is used the emulates a cluster. In the cluster case, FlinkClient (or StormSubmitter that used FlinkClient internally) is used to submit a topology to a (remotely) running Nimbus. However, I cannot make sense out of a localNimbus. Thanks for you help. -Matthias signature.asc Description: OpenPGP digital signature
Re: What is localNimbus?
Thanks! On 04/14/2015 06:28 PM, Bobby Evans wrote: LocalNimbus is something that is not really used. It provides a way for the StormSubmitter to be used when submitting a topology to a local mode cluster. No one uses it and in the past it didn't work, not sure if it works now or not. It is probably best to just not use it unless you really need to abstract out local mode from the topology code used to submit a topology. - Bobby On Tuesday, April 14, 2015 11:10 AM, Matthias J. Sax mj...@informatik.hu-berlin.de wrote: Dear all, I have a question about StormSubmitter class. It offers a method called setLocalNimbus(Nimbus.Iface localNimbusHandler). It sets the variable localNimbus and localNimbus is used within submitStormTopology. Can you explain what localNimbus is? As far as I understand Storm, there are two modes of operation: local and cluster. For local, a LocalCluster is used the emulates a cluster. In the cluster case, FlinkClient (or StormSubmitter that used FlinkClient internally) is used to submit a topology to a (remotely) running Nimbus. However, I cannot make sense out of a localNimbus. Thanks for you help. -Matthias signature.asc Description: OpenPGP digital signature
