#558·otter

batch延迟抖动

Author: deep011Created Jul 8, 2018Updated Mar 20, 2025

我们线上出现个问题,pipeline的delay时不时会超过60秒,现在定位到是selectTask类中,processTermin()函数在等待termin信号时,等不到termin信号,而重试了30次(sleep了30秒),结束后,又sleep了30秒导致的,如下图: image

startProcessTermin()函数中 image

通过开启dumpEvent日志观察,相关的processId已经load成功了,但termin信号没有创建

现在怀疑可能跟如下代码有关,需要帮忙确认下 @agapple image