batch延迟抖动
Author: deep011Created Jul 8, 2018Updated Mar 20, 2025
我们线上出现个问题,pipeline的delay时不时会超过60秒,现在定位到是selectTask类中,processTermin()函数在等待termin信号时,等不到termin信号,而重试了30次(sleep了30秒),结束后,又sleep了30秒导致的,如下图:

startProcessTermin()函数中

通过开启dumpEvent日志观察,相关的processId已经load成功了,但termin信号没有创建
现在怀疑可能跟如下代码有关,需要帮忙确认下 @agapple

Source: alibaba/otter