Suchergebnisse für Anfrage "apache-storm"
wie man den Parallelitätshinweis im Sturm stimmt
"Parallelitätshinweis" wird im Sturm verwendet, um eine laufende Sturmtopologie zu parallelisieren. Ich weiß, dass es Konzepte wie Worker Process, ...
Fügen Sie Reihen aus einer Sturmschraube in HBase ein
Ich möchte in der Lage sein, neue Einträge aus einer verteilten (nicht lokalen) Storm-Topologie in HBase zu schreiben. Es gibt einige GitHub-Projekte, die beides bietenHBase-Mapper [https://github.com/ptgoetz/storm-hbase]oder vorgefertigte ...
Apache Storm: Metrik-Protokolldatei ist leer
Ich versuche hier dem Beispiel zu folgen https: //www.endgame.com/blog/storm-metrics-ho [https://www.endgame.com/blog/storm-metrics-how] hier ist mein storm.yaml storm.zookeeper.servers: - localhost supervisor.slots.ports: - 6700 - 6701 ...
Wie kann ich Apache Storm in Eclipse debuggen?
Wir können Sturmgefäße mit bestimmten Parametern erzeugen. Müssen wir dieses Projekt jedoch sowohl lokal als auch remote (tatsächlich weit entfernt) debuggen? Wenn es ein einfaches Glas ist, können wir es debuggen. Hier stellen wir jar jedoch ...
Connection verweigert Fehler in Worker-Protokollen - Apache Storm
Ich sehe den folgenden Fehler in den Worker-Protokollen. Er tritt fast alle Millisekunden auf, aber der Cluster läuft einwandfrei. Ich wollte wissen, was dieser Fehler bedeutet und warum dies der Fall ist. Dies geschieht auf allen ...
Weg zum Arbeiter je nach Ergebnis in Sellerie?
Ich habe verwendetSturm in letzter zeit enthält das ein konzept namens
Warum sollte ich in Spout.nextTuple () keine Schleife oder Blockierung durchführen?
Ich habe viele Codefragmente gesehen, in denen eine Schleife innerhalb von @ verwendet wurdSpout.nextTuple() (um beispielsweise eine ganze Datei zu lesen und für jede Zeile ein Tupel auszugeben): public void nextTuple() { // do other stuff here ...
Wie eine bestimmte Methode aufgerufen wird, bevor eine Sturmtopologie beendet wird
Aufrufen einer bestimmten Methode vor dem Beenden einer Sturmtopologie. Ich habe eine Topologie im Sturm erstellt, ich wollte eine bestimmte Methode aufrufen, kurz bevor die Topologie getötet wird. ist eine vordefinierte überschriebene oder ...
Rebalancing Testamentsvollstrecker in Apache Storm
Ich versuche, die Anzahl der Executoren für einen Bolt in einer laufenden Apache Storm (0.9.5) -Topologie auszugleichen. Wenn ich den Befehl an den Nimbus-Knoten @ ausfüh./storm rebalance MyTopology -n 2 -e GreenBolt=4 Es akzeptiert die Eingabe ...