ahmedabu98 opened a new pull request, #40975: URL: https://github.com/apache/beam/pull/40975
Prism sometimes ends a job before its OnWindowExpiration callbacks can run. It also misframes Java’s chunked encoding of a lazy Iterable that crossed a stage. Both of these issues lead to lost or distorted batches coming out of GroupIntoBatches. Includes fix to run each runner transform in its own stage, so one GroupByKey can feed into another. -- 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]
