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
The following commit(s) were added to refs/heads/master by this push:
new a9ccb55 Increase Flink parallelism for ValidatesRunner tests
new d46da92 Merge pull request #8403: Increase Flink parallelism for
ValidatesRunner tests
a9ccb55 is described below
commit a9ccb551760ab6a5e71c35524309d4dc60d5894f
Author: Maximilian Michels <m...@apache.org>
AuthorDate: Thu Apr 25 19:19:38 2019 +0200
Increase Flink parallelism for ValidatesRunner tests
The parallelism had been dropped to 1 in the past. Since problems related
to a
higher parallelism have been fixed, we should increase this to 2 again.
---
runners/flink/flink_runner.gradle | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/runners/flink/flink_runner.gradle
b/runners/flink/flink_runner.gradle
index db6d3e3..e63e791 100644
--- a/runners/flink/flink_runner.gradle
+++ b/runners/flink/flink_runner.gradle
@@ -136,8 +136,7 @@ def createValidatesRunnerTask(Map m) {
def pipelineOptions = JsonOutput.toJson(
["--runner=TestFlinkRunner",
"--streaming=${config.streaming}",
- // TODO This should be changed to > 1
- "--parallelism=1",
+ "--parallelism=2",
])
systemProperty "beamTestPipelineOptions", pipelineOptions
classpath = configurations.validatesRunner
