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 f8d6b90841f869e618d8b0933b641c65537bf193 Merge: 0e581d4 1c26a51 Author: Maximilian Michels <[email protected]> AuthorDate: Fri May 3 17:21:25 2019 +0200 Merge pull request #8441: [BEAM-7192] Fix partitioning of buffered elements during checkpointing .../flink/FlinkStreamingTransformTranslators.java | 1 + .../runners/flink/translation/utils/NoopLock.java | 68 ++++++ .../wrappers/streaming/DoFnOperator.java | 152 ++++++++++---- .../streaming/ExecutableStageDoFnOperator.java | 5 + .../streaming/state/FlinkSplitStateInternals.java | 228 --------------------- .../streaming/FlinkSplitStateInternalsTest.java | 130 ------------ .../wrappers/streaming/DoFnOperatorTest.java | 38 +++- .../streaming/ExecutableStageDoFnOperatorTest.java | 2 +- .../wrappers/streaming/WindowDoFnOperatorTest.java | 2 +- 9 files changed, 219 insertions(+), 407 deletions(-)
