被压严重一般是sink 效率低或者计算过程有瓶颈,被压跟数据源数据多少没什么关系。你可以在web 界面查看哪个算子导致的,然后优化就可以了
发自我的iPhone ------------------ 原始邮件 ------------------ 发件人: 刘建刚 <liujiangangp...@gmail.com> 发送时间: 2021年3月5日 18:09 收件人: user-zh <user-zh@flink.apache.org> 主题: 回复:消息队列量级特别如何优化消费 本质原因是作业资源不足无法处理大量数据,好像只有扩大并发来解决了。 allanqinjy <allanqi...@163.com> 于2021年3月5日周五 上午10:48写道: > > > hi, > 由于消息队列量特别大,在flink接入以后被压严重。除了修改并行度以外还有没有其他的优化方案!!! > > > | | > allanqinjy > | > | > allanqi...@163.com > | > 签名由网易邮箱大师定制 > >