shunping commented on PR #35109: URL: https://github.com/apache/beam/pull/35109#issuecomment-2945055938
> The go to in this instance is check what happens on Dataflow. I'm pretty sure we've implemented things correctly and fixed legitimate bugs in the Prism implementation, but it's also an overall uncommon case, since windows + OnWindowExpiry is how that's handled usually in Java pipelines IIRC. > > I know the Python runner implementations are incomplete in many ways. Not sure where Flink is in this case, and Spark and Samza were further behind. Yes. I verified that the behavior of prism and dataflow is the same on these tests. The problem is related to FnApiRunner (which is the go-to runner if we specify DirectRunner in python). Filed an issue: #35168 -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
