Suchergebnisse für Anfrage "apache-storm"
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 ...
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 ...
Wie man Apache Storm im lokalen Cluster / Modus durch Eclipse debuggt
Mit den folgenden Fragen und Antworten konnte ich das Debuggen durch Eclipse auf einem Apache Storm-Cluster (lokal ausgeführt) aktivieren.Wie kann ich Apache Storm in Eclipse ...
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 wird die Größe der ausstehenden Warteschlangen von Bolt überwacht?
Meine Topologie hat einen oder zwei Engpässe. Die Kapazitätsmetrik in der Storm-Benutzeroberfläche ist nützlich, um diese zu identifizieren, aber die Größe der Bolt-Warteschlangen interessiert mich viel mehr. Mein Verständnis ist, dass jede ...
Graphite / Carbon Wie bekomme ich Metriken pro Sekunde?
Ich habedockerized graphite [https://github.com/projectvalis/dockerized_graphite] und arbeite mitdiese Bibliothek [https://github.com/verisign/storm-graphite], um Metriken aus einer Apache Storm-Topologie abzurufen. Ich erhalte Messdaten, aber ...
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 ...
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 ...
IRichBolt Fehler beim Ausführen der Topologie auf storm-1.0.0 und pyleus-0.3.0
Ich laufe Sturm Topologie "pyleus --verbose local xyz_topology.jar "mitstorm-1.0.0, pyleus-0.3.0, centos-6.6 und erhalte den Fehler Ausnahme im Thread "main" java.lang.NoClassDefFoundError: backtype / storm / topology / IRichBolt Running: ...
Streamparse wordcount example
Ich wollte Apache Storm verwenden, um von Kafka zu streamen. Ich fühle mich mit Python wohler und habe mich für streamparse entschieden https: //github.com/Parsely/streampars [https://github.com/Parsely/streamparse]). Das Beispiel für die ...