apache-storm

5Ciepło

3Odpowiedz

Projektuję prototypowy monitor czasu rzeczywistego do przetwarzania dość dużych ilości (> 30G/dzień) strumieniowych danych numerycznych. Chciałbym napisać to w Clojure, ponieważ język wydaje się dobrz

13Ciepło

2Odpowiedz

Interfejs Storm: Różnica między czasem wykonania i opóźnieniami procesu

Próbowałem udokumentować znaczenie wszystkich danych Storm dla mojego bieżącego projektu. Podczas tego procesu zebrałem dane z odpowiedzi tej grupy, a także github. Podczas gdy niektóre dane są dość w

5Ciepło

2Odpowiedz

Czy ponowne odtworzenie burzy jest krotką, które przetwarzanie zostało przekroczone?

Zostało wspomniane w dokumentacji sztormowej, że burza powtarza krotkę, która przerwała przetwarzanie. Moje pytanie brzmi: czy burza zrobi to automatycznie (bez wywoływania fail() na wylewce początkow

6Ciepło

1Odpowiedz

Tworzenie plików JAR Storma tylko w projekcie Gradle

Próbuję utworzyć projekt Gradle zawierający projekt Storm. Aby uruchomić ten projekt na Storm, muszę najpierw utworzyć plik JAR i pozwolić Stormowi uruchomić moją topologię, np. storm jar myJarFile.ja

45Ciepło

4Odpowiedz

Testowanie śrub burzowych i wylewek

Jest to ogólne pytanie dotyczące śrub do testowania jednostek i spustów w topologii burzowej napisanej w języku Java. Jakie jest zalecane praktyki i wytyczne dla testów jednostkowych (JUnit-?) Śruby i

5Ciepło

2Odpowiedz

Opóźnione przetwarzanie kolejki/komunikatu w czasie burzy

W topologiipodczas przetwarzania strumienia chcę opóźnić przetwarzanie niektórych wiadomości do momentu uzyskania niektórych przyszłych punktów w czasie. Jakie są rozsądne opcje, aby to zrobić? Dotych

6Ciepło

1Odpowiedz

Przykład burzy Twittera działającej w trybie lokalnym nie może usunąć pliku

Uruchomiłem projekt burzy (https://github.com/nathanmarz/storm-starter) i po uruchomieniu generuje on następujący błąd. 23135 [main] ERROR org.apache.zookeeper.server.NIOServerCnxn - Thread Thread[mai

14Ciepło

4Odpowiedz

Jak przesłać topologię w klastrze produkcji burzowej za pomocą IDE

Mam do czynienia z problemem Must submit topologies using the 'storm' client script so that StormSubmitter knows which jar to upload podczas przesyłania topologii do klastra produkcyjnego przy użyciu

7Ciepło

2Odpowiedz

Co to jest Trident State in Storm?

Jestem nowy w Trident in Storm. Łamie mi głowę nad TridentState. O ile mój trójząb rozumiejący utrzymuje stan (tj. Metadane) dla każdej partii (czy wszystkie krotki w partii są w pełni przetwarzane pr

10Ciepło

2Odpowiedz

Grupowanie w topologii burzy prosty agregacji

Próbuję napisać topologii, który wykonuje następujące czynności: dziobek, który subskrybuje kanał twitter (na podstawie słów kluczowych) śrubą agregacji że agreguje pewną liczbę tweetów (np. N) w kole