Details
-
Bug
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
-
None
Description
I have a stateful DoFn which has a timer on PROCESSING_TIME domain. While writing tests, I noticed that it does not react to `advanceProcessingTime()` on tests stream. Problem seems to be here:
I can only tell that patching this place works for direct runner tests. Not sure about broader impact on other runners since it is in `runner-core`
Attachments
Issue Links
- links to