-
- 霜花似雪 2022-08-07
数据可靠性：
Nimbus挂掉,换台机器重启就可
supervisor挂掉,将上面的worker迁移走就可以
worker挂掉,利用ack机制保证数据未处理成功,会通知spout重新发送.需要对记录通过msgId进行去重.也就是spout发送tuple时指定msgId,
spout也挂掉: 可以将数据记录到外部存储,设置checkpoint。- 0赞 · 0采集
-
- 小邪尊 2018-12-13
我的笔记我的笔记我的笔记2
- 0赞 · 0采集
-
- 小邪尊 2018-12-13
我的笔记我的笔记
- 0赞 · 0采集
-
- 凡简 2018-12-11
Spout数据故障
-
截图0赞 · 0采集
-
- 凡简 2018-12-11
故障处理3
-
截图0赞 · 0采集
-
- 凡简 2018-12-11
故障处理2
-
截图0赞 · 0采集
-
- 凡简 2018-12-11
故障处理：
-
截图0赞 · 0采集
-
- 凡简 2018-12-11
数据可靠性
-
截图0赞 · 0采集
-
- 慕尼黑5307359 2018-07-23
- Ack数据保障
-
截图0赞 · 0采集
-
- 慕尼黑5307359 2018-07-23
- 故障处理
-
截图0赞 · 0采集
-
- TimWaha 2018-05-10
Spout数据保障
-
截图0赞 · 0采集
-
- TimWaha 2018-05-10
Nimbus挂掉,换台机器重启就可 supervisor挂掉,将上面的worker迁移走就可以 worker挂掉,利用ack机制保证数据未处理成功,会通知spout重新发送.需要对记录通过msgId进行去重.也就是spout发送tuple时指定msgId, spout也挂掉: 可以将数据记录到外部存储,设置checkpoint。
- 0赞 · 0采集
-
- 慕九州4047082 2017-08-30
- Trident API替代了transcation API保证事务
-
截图0赞 · 1采集
-
- 炅93 2017-07-02
- Nimbus挂掉,换台机器重启就可 supervisor挂掉,将上面的worker迁移走就可以 worker挂掉,利用ack机制保证数据未处理成功,会通知spout重新发送.需要对记录通过msgId进行去重.也就是spout发送tuple时指定msgId, spout也挂掉: 可以将数据记录到外部存储,设置checkpoint。
- 0赞 · 0采集
-
- 王小呆 2016-12-26
- 成功ack{} 失败fail{}
-
截图0赞 · 0采集
-
- ymvkujn 2016-12-21
- Nimbus挂掉,换台机器重启就可 supervisor挂掉,将上面的worker迁移走就可以 worker挂掉,利用ack机制保证数据未处理成功,会通知spout重新发送.需要对记录通过msgId进行去重.也就是spout发送tuple时指定msgId, spout也挂掉: 可以将数据记录到外部存储,设置checkpoint。
- 1赞 · 3采集
-
- yg667 2016-08-03
- Spout容错
-
截图0赞 · 0采集
-
- yg667 2016-08-03
- Spout数据保障
-
截图0赞 · 1采集
-
- yg667 2016-08-03
- 故障处理1
-
截图0赞 · 0采集
-
- 积淀123 2016-07-13
- 数据保障
-
截图0赞 · 0采集
-
- 积淀123 2016-07-13
- 高可用
-
截图0赞 · 0采集
-
- 积淀123 2016-07-13
- 故障处理
-
截图0赞 · 0采集
-
- 慕丝8133230 2016-03-13
- 在emit中指定一个msgID(1111),然后如果这个这个spout挂掉，fail（）方法会根据msgID后跟踪，然后重新传送，ack()表示发送成功，这里可以写一些添加，更改等语句来操作数据
-
截图0赞 · 0采集
-
- 慕丝8133230 2016-03-13
- 1000千台机器，每台机器发生故障的概率数1/1000，那么每天也有将近一半以上的机器会发生故障
-
截图0赞 · 0采集
-
- yuyuyu 2016-02-18
- 一台机器 三年出一次故障 1000台机器 每天出故障的概率 1 - 0.999^1000 = 63.2% 故障处理 Nimbus故障，换台机器重启即可 Supervisor挂掉，迁移其上Worker即可 worker挂掉 数据丢失 处理超时 Spout数据保障 不丢：Acker机制保证数据如果未成功处理，可以及时发现，并通知Spout重发 不重：使用msgID去重 NextTuple中, emit时，指定msgID Bolt容错 emit时，锚定输入Tuple ack输入tuple Trident API 为用户屏蔽掉一些状态与计算一致的细节 使用户更方便的书写可容错的作业
- 0赞 · 2采集
数据加载中...