You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Boyuan Zhang (Jira)" <ji...@apache.org> on 2020/11/09 19:58:00 UTC

[jira] [Created] (BEAM-11210) ExecutableStageDoFnOperator should fire processing time timers properly instead of using Thread.sleep

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)