This is an automated email from the ASF dual-hosted git repository. lcwik pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 47a6114 [BEAM-9629] Fix several connection leak issues. (#12209) add ea965ca [BEAM-10420] Move restriction/watermark estimator state into PerWindowInvoker (#12192) No new revisions were added by this update. Summary of changes: sdks/python/apache_beam/runners/common.pxd | 3 +- sdks/python/apache_beam/runners/common.py | 34 ++++++------ .../runners/direct/sdf_direct_runner.py | 61 +++++++++++++++------- .../apache_beam/runners/worker/bundle_processor.py | 4 +- 4 files changed, 62 insertions(+), 40 deletions(-)