問題タブ [apache-storm]

私は嵐を使用しています... 時間をtopology.sleep.spout.wait.strategy.time.ms1 ミリ秒 (デフォルト) から 1 秒に増やしたいです。しかし、これがどこにあるのかわかりません。次のように定義されている構成クラスがあります

クラスがbacktype.storm.config

どのパラメータ名を使用すればよいですか? ですかemptyEmit？

編集: ネットを検索したところ、値が に存在することが指定されていますがdefault.yaml、Eclipse でそのようなファイルを見つけることができませんでした。

誰か助けてくれませんか？

Storm プロジェクトを含む Gradle プロジェクトをビルドしようとしています。このプロジェクトを Storm で実行するには、まず JAR ファイルを作成し、Storm にトポロジを実行させる必要があります。

Gradle はデフォルトで、コンパイル時と実行時の両方で Storm の依存関係を含んでいるため、問題が発生しています。これにより、次の例外が発生します。

与えられた例外は実際に役に立ち、問題の根本原因を突き止めます。解決策は、Gradle でコンパイルするときに Storm の依存関係を含めることですが、最終的な JAR ファイルを生成するときは含めません。

これを解決する方法を知っている人はいますか？StackOverflow の他の投稿では問題は解決しませんでした。コードを貼り付ける場合は、実際に実行されることを確認してください。

ありがとう！

高速/ビッグデータのストリーミングに関するリアルタイム分析に Twitter Storm を使用しています。どうすればブラウザ上でデータを効果的に視覚化できるかわかりません。つまり、Storm の処理速度は非常に速く、Storm はクラスターで動作しています。この表示の問題を解決するために、Node.js と D3.js の組み合わせを見つけました。私はUIやJavaScriptの世界から来たわけではないので、正しい方向に向かっているのか知りたいだけですか? この組み合わせが私に何をもたらすかについて、誰かが簡単な言葉で説明できますか?

私はプロトタイプのLambda システムを開発しており、私のデータは Flume 経由で HDFS にストリーミングされています。また、Storm にデータを取得する必要があります。Flume はプッシュ システムで、Storm はよりプルなので、スパウトを Flume に接続しようとするのは賢明ではないと思いますが、2 つの間にメッセージ キューが必要だと思います。繰り返しますが、これはプロトタイプなので、完璧ではなく、ベスト プラクティスを探しています。AMQP 準拠のキューを Flume シンクとして配置し、スパウトからメッセージをプルすることを考えています。

これは良いアプローチですか？もしそうなら、Flume の世界 (シンクとして) と Storm の世界 (スパウトとして) の両方で比較的堅牢なサポートを提供するメッセージ キューを使用したいと考えています。AMQP に移行すると、使用したい AMQP 準拠のキューを使用するオプションが与えられると思いますよね? ありがとう。

トポロジ (ローカル モード) の更新状態に問題があります - データベースに結果を書き込みたい:

この方法でトポロジを実行します。

データはデータベースから (MessageSubmittedOpaqueTransSpout によって) 正しく取得され、最初のトランザクションからのデータのみが partitionPersist によって stateFactoryDB (LocationDBFactory) に保存され、他のトランザクションは更新されないため、各フィルターによって出力されます。

LocationDBStateUpdater クラスの updateState メソッドのコード:

LocationDB クラスのコード:

ログ:

このログの冒頭に、次のような追加情報が表示されます。

私の問題はこの警告に関連している可能性がありますか? 私は何を間違っていますか？結果をデータベースに保存する別の方法があるでしょうか？

Linux を実行しているサーバーがありますUbuntu 12.04 LTS。通常、ubuntuという名前のユーザーを使用します。

最近、このサーバーに Storm をインストールしようとしましたが、この目的のために専用のユーザーストームを作成しました。

うっかりタイプミスで、 ubuntuからstormに切り替えたときに違うことに気づきました。

次のコマンドを使用して切り替えるとsudo su storm、すべて正常に動作します。

ただし、 を使用して切り替えるsudo su - stormと、ストーム プログラムが正しく起動しません。どちらのコマンドも嵐のユーザーの下に私を連れてきましたが。

誰でも理由を説明するのを手伝ってもらえますか? ありがとう。

テ

単純なワード カウント トポロジをローカル ストーム クラスターに送信しようとしています。まず、maven を使用してから、storm コマンド ライン クライアントを使用してみました。Eclipseを使用してJARファイルを作成しました。ただし、メインクラスが見つからないという例外がスローされます。何が問題なのか誰にも教えてもらえますか? 以下にコードと例外を添付します。

編集例外: