Hi all, I've spent some time on the rather hairy details of timers, batch, drain, and timer loops lately. We have some inconsistencies in this area that regularly bite users.
I've written up what I *think* are the desired semantics. some notes about the current status of implementation, and a few proposals for how we can improve things. https://s.apache.org/beam-timers-and-drain Please take a look! This stuff is hard and I could really use as many smart pairs of eyes on this as possible. Kenn