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/04 09:03:21 UTC
[beam] branch master updated (62d5f26 -> 133d798)
This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 62d5f26 Merge pull request #11595: [BEAM-9801] Fire timers set within timers in Spark
add 8c26045 [BEAM-9874] Support clearing timers in portable batch mode (Spark/Flink)
add 133d798 Merge pull request #11597: [BEAM-9874] Support clearing timers in portable batch mode (Spark/Flink)
No new revisions were added by this update.
Summary of changes:
.../beam/runners/core/InMemoryTimerInternals.java | 21 ++++++++-------------
.../functions/FlinkExecutableStageFunction.java | 6 +++++-
.../translation/SparkExecutableStageFunction.java | 6 +++++-
3 files changed, 18 insertions(+), 15 deletions(-)