This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch aaltay-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 7138af7991846001ad9499d14c6b85b9b5321ec1 Author: Ahmet Altay <aal...@gmail.com> AuthorDate: Thu Dec 5 17:57:01 2019 -0800 Changing _BatchSizeEstimator defaults to match BatchElements defaults On behalf of @katsiapis --- sdks/python/apache_beam/transforms/util.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/transforms/util.py b/sdks/python/apache_beam/transforms/util.py index 7a87e60..ea1498d 100644 --- a/sdks/python/apache_beam/transforms/util.py +++ b/sdks/python/apache_beam/transforms/util.py @@ -237,8 +237,8 @@ class _BatchSizeEstimator(object): def __init__(self, min_batch_size=1, - max_batch_size=1000, - target_batch_overhead=.1, + max_batch_size=10000, + target_batch_overhead=.05, target_batch_duration_secs=1, variance=0.25, clock=time.time,