diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle index ebed8e43389f..c3ae41767c78 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,