arunpandianp opened a new pull request, #38991: URL: https://github.com/apache/beam/pull/38991
Change LateDataDroppingDoFnRunner to not use state and timer internals directly. The state/timerinternals change when keys change in a multi key bundle and it is not safe for DoFnRunners to cache them for the entire bundle. Added a mechanism to poison WindmillStateInternals and WindmillTimerInternals which will help catch any such caching in future. StatefulDoFnRunner also caches state and timer internals directly, but it is not used by dataflow, so I didn't include them in this change. -- 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]
