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,
