有关flink数据消费速度的问题

Question

我现在遇到这样一种情况，flink从rabbitmq中消费数据，我先向rabbitmq中写入8万条数据，然后打开flink程序进行消费，flink程序以每秒1万条的速度消费数据，rabbitmq中的数据很快就没了，但是flink程序处理速度很慢（每秒几千条数据），这样其实是flink的消费速度大于了自身的处理能力，数据都缓存在了程序内部，如果数据源持续生产数据，那flink程序早晚会因内存溢出挂掉。我查了flink相关资料，flink自身有天然的反压机制，按理说，后面算子的处理能力慢会向前面的算子进行反压，直到反压source源的数据消费速度，但是我这面测试好像不是这样的，这是什么原因啊

Answer 1

适当减少taskmanager的内存进行观察？也许你的数据积压没有达到内存阀值？