通过metrics观察,下游的input queue都是0, 上游queue是满的




观察监控,发现当出现速率跌零的时候,下游的input queue是0
max by 
(exported_task_name)(flink_taskmanager_job_task_Network_Input_0_maxQueueLen{job_name=~'$job_name'})


此时上游的队列还是满的
(flink_taskmanager_job_task_Network_Output_0_maxQueueLen{job_name=~'$job_name'})








这个问题有没有什么想法

Reply via email to