如果锚定到消息id的其中一个元组失败,那么其他元组将完全处理还是被storm停止?
7cjasjjr1#
锚定到同一消息id的其他元组将继续正常处理。storm将立即使喷口处的消息id失败,这可能会导致喷口重试根元组。此行为的原因是,要让喷口尝试告诉所有可能正在处理锚定到失败消息id的元组的螺栓,该元组已经失败了,这将是困难的/代价高昂的。
1条答案
按热度按时间7cjasjjr1#
锚定到同一消息id的其他元组将继续正常处理。storm将立即使喷口处的消息id失败,这可能会导致喷口重试根元组。
此行为的原因是,要让喷口尝试告诉所有可能正在处理锚定到失败消息id的元组的螺栓,该元组已经失败了,这将是困难的/代价高昂的。