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/05/03 10:47:17 UTC

[beam] 01/01: Merge pull request #11595: [BEAM-9801] Fire timers set within timers in Spark

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 62d5f260fbfc70110b7d348145bd4c3384c44fcb
Merge: 360de38 1c0063a
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Sun May 3 12:46:54 2020 +0200

    Merge pull request #11595: [BEAM-9801] Fire timers set within timers in Spark

 .../functions/FlinkExecutableStageFunction.java    | 16 +---
 .../translation/PipelineTranslatorUtils.java       | 27 +++++--
 .../translation/SparkExecutableStageFunction.java  | 91 ++++++++++------------
 3 files changed, 59 insertions(+), 75 deletions(-)