This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5fd0010e52c5efee36760c302b03181e429da02f Merge: d4e3729 26b087b Author: Maximilian Michels <[email protected]> AuthorDate: Tue Sep 8 16:28:31 2020 +0200 Merge pull request #12759: [BEAM-10760] Generalize state cleanup optimization for global window .../wrappers/streaming/DoFnOperator.java | 24 ++- .../streaming/ExecutableStageDoFnOperator.java | 32 +--- .../streaming/state/FlinkStateInternals.java | 96 ++++++++--- .../wrappers/streaming/DoFnOperatorTest.java | 190 ++++++++++++++------- .../streaming/ExecutableStageDoFnOperatorTest.java | 39 +---- 5 files changed, 237 insertions(+), 144 deletions(-)
