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
