apache-storm

0熱

3答えて

MacBook ProにApache Storm（1.0.2）をセットアップしようとしていますが、トポロジをデプロイしようとするとタイムアウトの問題が発生しています。また、同じ例外が発生してUIがハングアップします。私はgithubのリポジトリからデフォルトstorm.yamlコンフィギュレーションを使用してい 3491 [main] INFO o.a.s.StormSubmitter - Gen

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にプロセスを再開した

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