目前现象如题。任务就是kafkaSource读取数据,简单过滤,然后window,然后输出到mysql。

目前来看运行后1-2min后cpu开始异常,不是马上异常。 异常时候window算子busy为100%。
window是event time window,配合自定义的
continuousProcessTriggerForEventTimeWindow(基于pt进行continuous
trigger,但是统计窗口是et window)。

请问这种怎么排查呢?目前来看应该是卡在某个地方了,cancel任务后,直接等到tm失败。window算子百分百不会cancel成功。

回复