This is an automated email from the ASF dual-hosted git repository.
boyuanz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from cd2ab9e Merge pull request #9298 from riazela/KafkaRateEstimation2
add 6454f72 [BEAM-7874], [BEAM-7873] Distributed FnApiRunner bugfixs
(#9218)
No new revisions were added by this update.
Summary of changes:
.../runners/portability/fn_api_runner.py | 115 +++++++++++++--------
.../runners/portability/local_job_service.py | 9 +-
2 files changed, 75 insertions(+), 49 deletions(-)