[beam] branch master updated (4335173 -> cfa4ffa9b)

[ib...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 4335173  Merge pull request #11585 from ibzib/BEAM-9758
     new 3a042b6  [BEAM-9801] Pass in fire timestamp and pane info to timer callback
     new dc8f17e  [BEAM-9733] Repeatedly fire in batch mode until there are no more timers
     new cfa4ffa9b Merge pull request #11492 from mxm/BEAM-9801

The 26793 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  |  7 ++++
 .../functions/FlinkExecutableStageFunction.java    | 40 ++++++++++++----------
 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 +-
 8 files changed, 63 insertions(+), 32 deletions(-)