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 > <[email protected]> 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
