[beam] branch master updated: [BEAM-7067] make cleanArtifactsPerJob configurable for Flink job server task

[mxm]

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 05758aa  [BEAM-7067] make cleanArtifactsPerJob configurable for Flink 
job server task
     new 2581565  Merge pull request #8293: [BEAM-7067] Make 
cleanArtifactsPerJob configurable for Flink job server Gradle task
05758aa is described below

commit 05758aa3536e5453153a860fb34eba4748e7aaa2
Author: Kyle Weaver <kcwea...@google.com>
AuthorDate: Fri Apr 12 11:01:49 2019 -0700

    [BEAM-7067] make cleanArtifactsPerJob configurable for Flink job server task
---
 runners/flink/job-server/flink_job_server.gradle | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/runners/flink/job-server/flink_job_server.gradle 
b/runners/flink/job-server/flink_job_server.gradle
index ebed8e4..c3ae417 100644
--- a/runners/flink/job-server/flink_job_server.gradle
+++ b/runners/flink/job-server/flink_job_server.gradle
@@ -96,7 +96,7 @@ runShadow {
   if (project.hasProperty('artifactsDir'))
     args += ["--artifacts-dir=${project.property('artifactsDir')}"]
   if (project.hasProperty('cleanArtifactsPerJob'))
-    args += ["--clean-artifacts-per-job"]
+    args += 
["--clean-artifacts-per-job=${project.property('cleanArtifactsPerJob')}"]
   if (project.hasProperty('flinkMasterUrl'))
     args += ["--flink-master-url=${project.property('flinkMasterUrl')}"]
   if (project.hasProperty('flinkConfDir'))
@@ -120,7 +120,7 @@ def portableValidatesRunnerTask(String name, Boolean 
streaming) {
   createPortableValidatesRunnerTask(
     name: "validatesPortableRunner${name}",
     jobServerDriver: "org.apache.beam.runners.flink.FlinkJobServerDriver",
-    jobServerConfig: 
"--clean-artifacts-per-job,--job-host=localhost,--job-port=0,--artifact-port=0",
+    jobServerConfig: "--job-host=localhost,--job-port=0,--artifact-port=0",
     testClasspathConfiguration: configurations.validatesPortableRunner,
     numParallelTests: 1,
     pipelineOpts: pipelineOptions,