[beam] branch aaltay-patch-1 created (now 7138af7)

[al...@apache.org]

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

altay pushed a change to branch aaltay-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git.


      at 7138af7  Changing _BatchSizeEstimator defaults to match BatchElements defaults

This branch includes the following new commits:

     new 7138af7  Changing _BatchSizeEstimator defaults to match BatchElements defaults

The 1 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.

[beam] 01/01: Changing _BatchSizeEstimator defaults to match BatchElements defaults

[al...@apache.org]

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 <aa...@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,