你好，
消费速度跟不上写入速度，通过调试并发可以提高消费，但是不能一直这样靠着修改并发度来做优化。你说的看哪个算子问题，能具体点吗？怎么就算有问题了？一旦被压了，基本你看算子，基本的被压肯定都是正常的只有source那里才是high，被压会一级一级的反到source。你看算子的metrics也能只能看进入的量，出去的量，sink的出去的量是第三方flink
ui上应该也看不到，这样如何排查是哪个算子的具体问题？你们是有什么好的方法吗？
| |
allanqinjy
|
|
[email protected]
|
签名由网易邮箱大师定制
在2021年03月5日 14:22，Michael Ran<[email protected]> 写道：
看看哪个算子问题，增加那个算子并发。 或者优化那个算子执行。 <br/><br/><br/>先找找原因
在 2021-03-05 11:05:14，"allanqinjy" <[email protected]> 写道：
hi,
由于消息队列量特别大，在flink接入以后被压严重。除了修改并行度以外还有没有其他的优化方案!!!
| |
allanqinjy
|
|
[email protected]
|
签名由网易邮箱大师定制
