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
