[ https://issues.apache.org/jira/browse/BEAM-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yichi Zhang resolved BEAM-7642. ------------------------------- Resolution: Fixed > (Dataflow) Python AfterProcessingTime fires before defined time > --------------------------------------------------------------- > > Key: BEAM-7642 > URL: https://issues.apache.org/jira/browse/BEAM-7642 > Project: Beam > Issue Type: Bug > Components: sdk-py-core > Reporter: Mikhail Gryzykhin > Assignee: Yichi Zhang > Priority: Major > Fix For: 2.16.0 > > Time Spent: 1h 20m > Remaining Estimate: 0h > > [https://stackoverflow.com/questions/56700913/why-my-data-in-apache-beam-is-emitted-after-a-few-minutes-instead-of-10h] > > User on StackOverflow has a problem that AfterProcessingTime on global window > fires before allocated time (10h). It dumps events within first > minutes/seconds and then drops the rest due to window closed. > Code user provided seems valid. I tried to verify time units accepted by the > method, but I couldn't track it all the way through the code. -- This message was sent by Atlassian Jira (v8.3.2#803003)