scott-strong commented on issue #21882: URL: https://github.com/apache/beam/issues/21882#issuecomment-1302462637
@pabloem do you have any suggestions on how we can fix this? It's currently blocking us from upgrading our pipelines that use fixed windows. I was thinking maybe we need to handle the work being done in `finish` using a timer and setting an expiry. It seems like we're basically just buffering and flushing, but need to make sure the buffer get left with elements. I was also wondering if we should be using dedicated state mechanisms to handle this. It seems like we should be adding these elements to a `BagState` instead of a local variable. I started working on it but wanted to get your opinion since you originally wrote this feature. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
