क्या तूफान फिर से खेलता है जो प्रसंस्करण का समय समाप्त हो गया है?

Question

तूफान प्रलेखन में उल्लेख किया गया है कि तूफान दोहराता है जो प्रसंस्करण का समय समाप्त हो गया है। मेरा सवाल यह है कि अगर तूफान स्वचालित रूप से ऐसा करता है (मूल स्पॉट पर कॉलिंग असफल() के बिना) या यह ट्यूपल को फिर से चलाने के लिए मूल स्पॉट की ज़िम्मेदारी है (असफल() को कॉल किया जाता है और रीप्ले को अंदर या यहां तक ​​कि कहीं भी लागू किया जाना चाहिए)?

Answer 1

टाइमआउट पर उचित रीप्ले करने के लिए, आपको स्पॉट से निकलने पर आईडी के साथ टुपल एंकर करना होगा। जब टाइमआउट होता है, जो भी आप एंकर के रूप में उपयोग करते हैं, उसे असफल विधि में वापस कर दिया जाता है (विफल (ऑब्जेक्ट एंकर आईडी))। अब आप टाइमआउट टुपल के साथ फिर से चलाने के लिए असफल/टाइमडआउट टुपल के एंकर आईडी का उपयोग कर सकते हैं या कुछ भी करना चाहते हैं। प्रत्येक एंकर आईडी अद्वितीय होना चाहिए। एंकर आईडी का एक उदाहरण डेटाबेस आईडी है। जब आप विफल हो जाते हैं, तो आप अपने tuple को फिर से बनाने और इसे फिर से निकालने के लिए डेटाबेस आईडी का उपयोग कर सकते हैं। तो अपने प्रश्न का उत्तर देने के लिए आपके पास असफल के अंदर अपना रीप्ले तर्क होना चाहिए और आप अपने tuple को फिर से बनाने के लिए anchorId का उपयोग कर सकते हैं। उम्मीद है कि यह जानकारी

Answer 2

http://storm.apache.org/documentation/Guaranteeing-message-processing.html से

,

अगर टपल बार-आउट तूफान Spout

तो हाँ, fail बुलाया जाएगा पर fail विधि कॉल करेंगे।