apache-storm

2熱

1答えて

Apache-stormスーパーノードがマルチノード環境でトポロジを実行しようとすると死んでしまう

私は最も簡単な飼い犬/嵐/トポロジー/ muti-nodeテストを行っています。すべては問題ありませんが、スーパバイザは最後の段階で停止します（嵐のスーパーバイザがトポロジを実行しようとしたとき）。私は3つのVM（ubuntu-16.04.2）ホストを持っています。各ホストが（依存関係を含む）は、同じ環境を有する： - 飼育係-3.4.10 - アパッチ・ストーム1.1.1 3つのホスト名：

0熱

1答えて

Apache Stormの非アクティブ化トポロジによりCPU使用率が高くなる

無効なApacheストームトポロジのCPU使用率が高い問題が発生しています。以下の手順で問題を確実に再現できますが、正確な原因や解決策がまだ特定されていません。環境は1つのトポロジが実行されているストームクラスタです（トポロジは非常に単純ですが、感嘆符の例を使用しています）。それは無効です。最初は、通常のCPU使用率があります。しかし、すべてのスーパーバイザですべてのトポロジJVMプロセスを停止

0熱

1答えて

「エラー：メインクラスの検索またはロードできませんでした」「嵐ジャー」を使用しているときにエラーを

私はJavaのバージョン、CLASSPATHことを確認し、Javaのパスとプロパティ]> [実行/デバッグ設定を構築しかし、私はこの問題を解決することはできませんエラーCould not find or load main class この問題を解決するにはどのような情報が必要ですか？これは私が、私はそれを修正する必要があることを考えるエラーと私のコンピュータ情報 #storm jar tim

0熱

1答えて

複数のlog4jファイルのためにストームトポロジが送信されない

複数のlog4jエラーのためにストームトポロジの送信が失敗しています。ローカル・エクリプスでは、動作しています。しかし、Stormクラスタでトポロジを送信すると、トポロジの送信が失敗します。ストームバージョン1.1.1 & kafka_2.9.2（0.8.1.1）を使用しています。 eclipseでmavenを通してjarから来るlog4jファイルを見つけるにはどうすればよいですか？ <d

0熱

1答えて

storm-kafka統合エラー

私は以下のエラーに遭遇しています。キュレーターのjarファイルはmapr libというサーバーclasspathを参照していて、キュレーターjarファイルを含んでいます。私は最終的な実行可能なjarファイルにキュレーターjarをパッケージ化していません。 java.lang.NoSuchMethodError: org.apache.curator.utils.ZKPaths.mkdirs(Lo

0熱

1答えて

Apache StormのSchedulerとStrategyの違いは何ですか

私はApache Stormを勉強しています。私はソースコード& &デベロッパードキュメント& & JavaDoc & &その他のStormについてのブログを読んでいます。私は多くの質問を混乱させました。ほとんどのドキュメントとブログでは、Storm ClusterがトポロジーをWorkersに割り当てると、異なるスケジューラが異なる割り当てスタイルにつながると言いました。しかし、私は、Stor

-1熱

1答えて

メッセージ処理が1回で済むとトライデントを使用する意味がわかりません

メッセージを1回だけ処理する必要がある場合、はトライデントを使用する必要があります。 BaseRichSpoutでack（）とfail（）を実行しますか？トライデントの機能（groupping、jonning ..など）が必要ない場合は、BaseRichを使用できますか？

0熱

1答えて

Kotlin：フィルタリングされた（おそらく空の、多くとも1つの要素の）リストをループする

私はタイルを取得します。タプルはという種類の値を含むMyClassの値を含んでいます。ボルトの最後には、最初から処理が行われた時刻（startTime）を記録したいと思います。だから私はできる： override fun doExecute(input: Tuple): Boolean { ... // my processing logic input.values.filt

0熱

1答えて

スパウトからのストームトポロジの殺し

ストームトポロジを継続的に実行したくないユースケースがあります。代わりに、指定された時間に処理されるべき入力（10K +）のセットがあり、Spoutはこれらの入力を継続的に放出し、トポロジ内の残りのボルトによって処理されます。すべての入力が処理されると、私の吐き気の中でnextTupleから放出するものはありません。この時点で、トポロジがスリープ状態になり、毎日午前12:00にプロセスを再開した