当前场景的架构演进过程。首先，在 Flink + MQ 架构中，当前场景的消息类型为 Changelog。因为 MQ 并不支持传递 Changelog 类型数据，所以在指标计算之前，需要按照用户粒度 + 『直播间』粒度，使用 Last_Value 等聚合函数手动构建 Retract 消息，再根据『直播间』 ID 聚合，得到『直播间』的用户举报人数。在此过程中，Flink 链路会产生大量的 Keyed State，并且由于审核完成时间不固定，无法确定状态到底需存储多久，这导致 Flink 任务中的状态会线性膨胀，引发任务不稳定。
最终，团队采用 Doris 方案实现，将用户的举报明细直接写入 Doris 的明细表中，在查询服务层实现整体的计算逻辑。根据主播 ID 和『直播间』的开播 / 关播时间，点查 Doris 明细表，解决了 Flink + MQ 链路中的大状态问题。但是，为保障 Doris 集群的整体稳定性，对接口进行了限流，将限流阈值设置为 150 QPS。因此，当查询遇到高并发时，经常会触发限流，影响用户的查询体验。
日前，记者从中国科学院长春光机所获悉，该所光学系统先进制造全国重点实验室先进光学制造团队，荣获中国科学院2025年度先进集体称号。 多年来，团队坚持党建引领科研，发挥体系化建制化优势，在先进光学制造上不断创新…
随着2026餐饮行业标准化发展，商用厨轨拌饭炒海苔碎的选择变得更为关键。本文为您详解商用拌饭炒海苔碎的选型逻辑、成本控制、应用场景，助您找到高性价比的0添加产品。重点探讨预算范围内如何选择符合卫生安全规范且口味佳的产品。
侯呈玥在剧中饰演温凝这一角色，展现了她精准的表演技巧。 这部剧的主演姚冠宇和侯呈玥是首次合作，两人在剧中的CP感十足，默契度也非常高。姚冠宇和侯呈玥都与导演有过多次合作，他们的默契也为这部剧的质量提…
他们直言王文林的相声水平一般，台风也不够出彩，撑不起大场面，能拿到150元一场，已经是给多了。 更有网友替王文林抱不平，指出当年与『郭德纲』的合作中，他也曾为相声事业贡献过力量，绝不该被全盘否定。不可否认，王…
# 张凌赫方回应常驻跑男 近日，张凌赫是否将常驻《奔跑吧》这一话题突然成了网络热议的焦点，短短半天内，相关话题的阅读量飙升至1800万，瓜友们纷纷搬好小板凳、准备好瓜子和饮料，期待一场大帅哥撕名牌的精彩对决。…
当前网址：