beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [beam] branch release-2.21.0 updated (9364bba -> fe15aec)
Date Mon, 04 May 2020 08:51:00 GMT
This is an automated email from the ASF dual-hosted git repository.

mxm pushed a change to branch release-2.21.0
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 9364bba  Merge pull request #11537: [BEAM-6661] Get rid of a few logging annoyances
for execution and shutdown
     new 6f1c2f4  [BEAM-9801] Pass in fire timestamp and pane info to timer callback
     new 13f1e7b  [BEAM-9733] Repeatedly fire in batch mode until there are no more timers
     new f2bfed6  Merge pull request #11595: [BEAM-9801] Fire timers set within timers in
Spark
     new fe15aec  [BEAM-9874] Support clearing timers in portable batch mode (Spark/Flink)

The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../beam/runners/core/InMemoryTimerInternals.java  | 22 ++---
 .../functions/FlinkExecutableStageFunction.java    | 32 +++-----
 .../translation/PipelineTranslatorUtils.java       | 27 ++++--
 .../translation/SparkExecutableStageFunction.java  | 95 ++++++++++------------
 sdks/python/apache_beam/runners/common.py          | 16 ++--
 .../runners/direct/transform_evaluator.py          |  4 +-
 .../runners/portability/fn_api_runner/execution.py |  6 ++
 .../runners/portability/fn_api_runner/fn_runner.py |  7 +-
 .../portability/fn_api_runner/fn_runner_test.py    | 12 ++-
 .../apache_beam/runners/worker/operations.py       |  3 +-
 10 files changed, 121 insertions(+), 103 deletions(-)


Mime
View raw message