嵐の文書では、処理がタイムアウトしたタプルを嵐が再生していると言われています。私の質問は、嵐がこれを自動的に(原点スパウトでfail()を呼び出さずに)行うのか、それともタプルを再生するために元のスパウトの責任であるか(fail()が呼び出され、リプレイが外部)? http://storm.apache.org/documentation/Guaranteeing-message-processing.htmlから処理がタイムアウトした嵐の再生タプルはありますか?
5
A
答えて
6
タイムアウトに適切な再生をするには、吐水口から放出するときにタプルにIDを固定する必要があります。タイムアウトが発生すると、アンカーとして使用したものがfailメソッド(fail(object anchorId))に返されます。これで、タイムアウトタプルでやりたいことを再生するために、失敗した/タイムアウトされたタプルのanchorIdを使うことができます。各アンカーIDは一意でなければなりません。アンカーIDの例は、データベースIDです。タプルが失敗すると、databse idを使用してタプルを再作成して再表示することができます。だからあなたの質問に答えるには、失敗の内部にリプレイロジックを持っていなければならず、anchorIdを使ってタプルを再作成することができます。この情報が役立つことを願っています
4
、
タプル回アウトストームはそうです、
fail
が呼び出されますSpout
にfail
メソッドを呼び出します場合。
関連する問題
- 1. SqlExceptionが発生することがあります:タイムアウトがタイムアウトしました
- 2. バッチ処理を処理するJavaキューオブジェクトまたはメカニズムがありますか?
- 3. Paypal API DoDirectPaymentでエラー10001が発生しました:タイムアウト処理リクエスト
- 4. getJSONタイムアウト処理
- 5. 申し訳ありません、あなたのリクエストの処理中にエラーが発生しました
- 6. 未処理の例外が発生した場合は、WPFアプリケーションをシャットダウンする必要がありますか?
- 7. XSLT処理コマンドラインツールはありますか?
- 8. NServiceBus:「失敗した処理が完了しました」メッセージ処理のイベントが発生します。
- 9. このPHPスクリプトをより適切に処理する方法はありますか? - タイムアウトの問題
- 10. Actionmailer、タイムアウトし、エラーがあれば再開しますか?
- 11. ReadTimeoutHandlerのタイムアウトの処理
- 12. 申し訳ありませんが、リクエストの処理中にエラーが発生しました。 MVC3モデルエンティティで
- 13. ハードウェアとタイムアウトの処理.net
- 14. OutputStream close()関数で発生したIOExceptionを処理するか無視する必要がありますか?
- 15. SSL_read()はSSL_ERROR_WANT_WRITEを処理する必要がありますか?
- 16. Drools:droolsイベント処理に問題がありました
- 17. 非常にスケーラブルで効率的な残りのjson処理にスプレーまたは再生を使用する必要がありますか?
- 18. ハンドルをSocket.ReceiveFromで処理すると、スマーミングコンソールなしでタイムアウトが発生する
- 19. Handler.postDelayedにタイムアウトがありますか?
- 20. ワークフローで未処理の例外が発生した後の再試行期間
- 21. 誰がHttpPostedFile.InputStreamを処理する責任がありますか?
- 22. NetBeansのRパッケージを処理するメソッドまたはプラグインはありますか?
- 23. MySqlException:タイムアウトがタイムアウトしました - 接続タイムアウトを増やしても効果がありません
- 24. ajax jqueryの処理中にエラーが発生しました
- 25. PaperclipError、 "サムネイルの処理中にエラーが発生しました..."
- 26. runMidlet.exeで未処理のWin32例外が発生しました
- 27. Django UserProfileフォームの処理中にエラーが発生しました。
- 28. ブーストmsmのエラー処理でエラーが発生しました
- 29. 並行処理は並列処理ではありませんか?
- 30. 大きなリモートファイルを処理する際にタイムアウトの問題が発生する
Spoutのfail()メソッドでどのボルトが失敗したのか知る方法はありますか?基本的には、ack()またはfail()を実行しているときに、タプルにボルト固有の情報を送りたいと思います。どのようにこれを行うことができますか? –