lostluck commented on issue #32559: URL: https://github.com/apache/beam/issues/32559#issuecomment-2375192947
https://github.com/apache/beam/issues/32559#issuecomment-2374686579 is probably a separate issue. I would not yet vouch for the behavior of ProcessingTime timers yet without using TestStream, as we have yet to put in the ability for Prism actually execute in "real" time, so it's not going to execute in a comparable fashion to a production runner like Dataflow. It's important to note that setting the OutputTimestamp only arrests the *downstream* watermark, not the upstream watermark which determines EventTime firing. Also, outside of literally blocking the execution *within* a DoFn, Process bundle will eventually complete when all user code has returned. The nil/empty bytes issue might have been #32245 which either cause corruption or zeroing when built with Go 1.23.0+. -- 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]
