[beam] branch master updated: [BEAM-7859] set SDK worker parallelism to 1 in word count test

[go...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 4dbfc6f  [BEAM-7859] set SDK worker parallelism to 1 in word count test
     new fba3524  Merge pull request #9421 from ibzib/sdk-worker-test
4dbfc6f is described below

commit 4dbfc6f0587f4ddea56e7ef5a1589f03b3acf8bd
Author: Kyle Weaver <kc...@google.com>
AuthorDate: Fri Aug 23 14:34:57 2019 -0700

    [BEAM-7859] set SDK worker parallelism to 1 in word count test
---
 buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy | 1 +
 1 file changed, 1 insertion(+)

diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
index 8a441662..1f353a2 100644
--- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
+++ b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -2002,6 +2002,7 @@ class BeamModulePlugin implements Plugin<Project> {
               "--experiments=worker_threads=100",
               "--parallelism=2",
               "--shutdown_sources_on_final_watermark",
+              "--sdk_worker_parallelism=1",
             ]
             if (isStreaming)
               options += [