apache-storm

0熱

1答えて

私はちょうど嵐で始まります。私はスパウト（1エグゼクティブ）とボルト（4エグゼクティブ）の簡単なトポロジを持っています。スパウトとボルトは "シャッフルグループ化"で接続されています。スパウトは、スパウトと同じホストで実行されているボルトエグゼキュータのサブセットにのみタプルを送信します。これは予想されますか？実行する場所に関係なく、すべてのボルトエグゼキュータに負荷を分散する方法はありますか

0熱

1答えて

タプルを放つべきではないApacheの嵐の最終的なボルト？

Eがデータベース、任意のタプルを放出するため、無ニーズの情報を持続し、最終的な1、である。我々は次のトポロジ spout A -> bolt B -> bolt C -> bolt E とボルトを持っていると仮定すると、その後、私は例外 Exception in thread "main" java.io.IOException: org.apache.storm.thrift.protoco

0熱

1答えて

Apache StormのTupleWindowの開始/終了時間

私はprofillingアプリケーションを開発しており、Apache StormのCDR（Call Detail Record）データで動作しています。アプリケーションの主な目的は、指定された時間ブロック（すべてのウィンドウ内）でCaller TotalCallCountとTotalCallDurationを抽出することです。面白いことに、私はSlidingWindowテクニックを使用したいと思い

0熱

1答えて

Apache Stormでのユニットテスト - BaseRichBoltでのタイムアウト（BaseBasicBoltではなく）

私はStormボルト（Java）のユニットテストを実装しようとしています。以下のコードは正常に動作し、嵐1.0.3に成功で終了します。 Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.887 secしかし、私はBaseRichParrotBoltにライン46上BaseBasicParrotBoltを変更、アサーシ

1熱

1答えて

HDInsight Stormはサンプルアプリケーションを使用してEventHubsを読み書きできません

のサンプルEventHubアプリケーションを実装しようとしていますが、エラーが表示されます。私はこの文書で与えられた全く同じ手順に従った。私はHDInsight 3.5、Storm 1.0.1.2.5.4.0-121にあります。 Storm UIから見たEventHubReaderのものです。 com.microsoft.eventhubs.client.EventHubException: or

0熱

1答えて

HDFSでの並列処理のヒント

私はApacheの嵐に取り組んでおり、HDFSを使用しています。もし私が並列1のヒントを使うと、1つのファイルが作成され、ファイルにデータを書き込んで正常に動作します。しかし、私が3にボルトのための並列性のヒントを増加させると、それは3つのファイルを作成し、1つのファイルだけにデータを書き込んでいます。私のアプリケーションは、1つの注ぎ口と2本のボルト（XboltとYblot）を有する並列ヒン

1熱

1答えて

Apache Storm Supervisor Error：メインクラスorg.apache.storm.daemon.supervisorを見つけられませんでした。

Windows 7ワークステーションから嵐のスーパーバイザを起動しようとすると、次のエラーが表示されます。エラー：メインクラスを見つけられませんでしたorg.apache.storm.daemon.supervisor。エラーなしでnimbusを正常に起動できました。 P.S：当初、ニンバスと同じ問題がありました。それから私はApache Storm Nimbus Error: Could no

0熱

3答えて

EsperとApache Stormの違いは？

私の目標は、CEPを使用してデータのストリームを処理してイベントコンシューマへのイベント通知を生成するパブリッシャとコンシューマの分散アプリケーションを作成することです。 EsperとApache Stormの違いは何ですか？私はストームがエスパーだけで何をするのか達成することができますか？そして、いつ私はエスパーとストームを統合すべきですか？私は混乱しています。私はEsperが同じ機能を提供

0熱

1答えて

Storm 1.0.2 hdfs-boltデータが送信されない場合のタプル

私はKafka SpoutからJSONデータを受け取り、2つのボルトを処理し、hdfs-ボルト。 Kafka 0.8.2.1とHadoop 2.5.0でStorm 0.9.6を使用すると、これは完全に機能しました。私がこれを実装した生産システムは、ツールをStorm 1.0.2、Kakfa 0.10.1.0、およびHadoop 2.6.0にアップデートすることです。上記のバージョンのパッケージ情報

0熱

1答えて

ストームUIが正しく表示されないacked

私はApache Kafka_2.11-0.10.1.0でApache Storm 1.0.3を統合しました。ストームは、カフカのトピックから1つまたは2つのメンセージを正しく読んでいますが、最初のボルトがタプルを受け入れると、このアクシデントはストームUIに表示されません。何が問題ですか？その他の質問：Stormがkafkaトピックから10個または19個のメッセージを読むと、その時点でStor