写HBase慢造成消息堆积，有没有异步IO可以用于sink或者outputFormat的方法？
业务场景中，需要将处理后的消息写入到HBase中，由于写入HBase慢，引起消息堆积。 通过Stream API 有没有方法可以异步批量发送？ 谢谢！*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
我们之前的处理方式是批量写入HBase，或者通过其他手段加速写入HBase。 如果HBase现在确因种种原因无法写入或者写入过慢，那么这个时候应该造成反压，逐渐减缓直到停止对上游消息队列的消费。 一般入库的服务（或者说实时性要求不高）和实时性要求强的服务尽可能不要放在同一个Job里面比较好。
仅供参考。*来自志愿者整理的flink
2021-12-07 15:23:10赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
