ExecutableStageDoFnOperator should fire processing time timers properly instead of draining it directly when close() happens
Open
bug
flink
P3
runners
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
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.
Imported from Jira [BEAM-11210](https://issues.apache.org/jira/browse/BEAM-11210). Original Jira may contain additional context.
Reported by: boyuanz.
Contributor guide
Assessment
This issue has not been assessed yet.