You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2020/04/24 10:45:47 UTC

[beam] 01/01: Merge pull request #11362: [BEAM-9733] Improve watermark and timer handling

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 4797f310b6671de6fd703502520f4b012b655c82
Merge: e55a7b3 643945a
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Fri Apr 24 12:45:33 2020 +0200

    Merge pull request #11362: [BEAM-9733] Improve watermark and timer handling

 runners/flink/flink_runner.gradle                  |   5 +-
 .../functions/ImpulseSourceFunction.java           |  12 +
 .../wrappers/streaming/DoFnOperator.java           | 213 ++++++++++------
 .../streaming/ExecutableStageDoFnOperator.java     | 204 +++++++++++----
 .../wrappers/streaming/SplittableDoFnOperator.java |   4 +
 .../beam/runners/flink/FlinkSavepointTest.java     |  34 +--
 .../runners/flink/PortableTimersExecutionTest.java |  35 ++-
 .../functions/ImpulseSourceFunctionTest.java       |  17 +-
 .../wrappers/streaming/DoFnOperatorTest.java       |   5 +-
 .../streaming/ExecutableStageDoFnOperatorTest.java | 273 +++++++++++++++++----
 .../wrappers/streaming/WindowDoFnOperatorTest.java |   4 +-
 11 files changed, 587 insertions(+), 219 deletions(-)