Zastąp burzę.yaml / ustawienie w śrubach / wylewkach Java - apache-storm

Potrzebujesz pomocy z Tuning apache storm. Uruchomiłem polecenie na serwerze nimbus, aby zwiększyć liczbę końcówek wylewki i śrubę.

Moje pytanie jest proste. Czy polecenie:

rebalance burzy TopologyName -e spout / or / bolt =

Czy to przesłonić liczbę równoległych wskazówek w kodzie Java?

Uruchomiłem to i nie widziałem zmiany w interfejsie GUI.

Czy istnieje również sposób na zastąpienie parametru w pliku storm.yaml?

topology.max.spout.pending: 1000

Dzięki za wszelką pomoc w tej sprawie. Mam świetną książkę o Storm, ale nie mogę się dowiedzieć, dlaczego moje zmiany nie zostały odzwierciedlone po ponownym zrównoważeniu ...

Odpowiedzi:

Czy ustawiłeś wystarczająco wysoką liczbę zadań? Zobacz tutaj, aby uzyskać więcej informacji:

1. Rebalancing executors w Apache Storm
2. https://storm.apache.org/documentation/Understanding-the-parallelism-of-a-Storm-topology.html

Więc tak, zastępuje równoległą podpowiedź, ale tylko w razie potrzeby.

I tak, możesz użyć storm.yaml ustawić domyślna "Maks. oczekujący" parametr. Ta wartość może być zmieniana dla każdej topologii indywidualnie poprzez nadpisanie wartości domyślnej w konfiguracji zapewnianej dla topologii podczas przesyłania:

Config conf = new Config();
conf.setMaxSpoutPending( /* put your value here */ );
StormSubmitter.submitTopology("topologyName", conf, builder.createTopology());