Boyuan Zhang created BEAM-11210:
-----------------------------------
Summary: ExecutableStageDoFnOperator should fire processing time
timers properly instead of using Thread.sleep
Key: BEAM-11210
URL: https://issues.apache.org/jira/browse/BEAM-11210
Project: Beam
Issue Type: Improvement
Components: runner-flink
Reporter: Boyuan Zhang
We hit this case when processing time timer holds the watermark but at the same
time we are closing the operator.
One typical case is when SDF sets timer for rescheduling residuals.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
