You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2018/11/30 11:15:54 UTC

[beam] 04/07: [BEAM-5978] Increase portable wordcount threads to avoid dead lock

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

mxm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 63a4c182e501b4b7a4d3c2b5d5012cbd12e4260d
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Thu Nov 29 19:05:13 2018 -0800

    [BEAM-5978] Increase portable wordcount threads to avoid dead lock
---
 sdks/python/build.gradle | 1 +
 1 file changed, 1 insertion(+)

diff --git a/sdks/python/build.gradle b/sdks/python/build.gradle
index d26e292..7c54239 100644
--- a/sdks/python/build.gradle
+++ b/sdks/python/build.gradle
@@ -267,6 +267,7 @@ task portableWordCount(dependsOn: 'installGcpTest') {
             "--input=/etc/profile",
             "--output=/tmp/py-wordcount-direct",
             "--runner=PortableRunner",
+            "--experiments=worker_threads=100",
     ]
     if (project.hasProperty("streaming"))
       options += ["--streaming"]