Merge pull request apache#10954 from ibzib/BEAM-9373

[BEAM-9373] Spark/Flink tests fix string concat
grtheod · Feb 27, 2020 · b9ca34d · b9ca34d
2 parents f4f12b1 + 41e9520
commit b9ca34d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle
@@ -220,7 +220,7 @@ def addTestJavaJarCreator(String pyVersion) {
                 "--python_root_dir ${project.rootDir}/sdks/python",
                 "--python_version ${pyVersion}",
                 "--python_container_image ${project.docker_image_default_repo_root}/"
-                        + ${project.docker_image_default_repo_prefix}
+                        + "${project.docker_image_default_repo_prefix}"
                         + "python${pyVersion}_sdk:${project.sdk_version}",
         ]
         args "-c", "../../../portability/test_pipeline_jar.sh ${options.join(' ')}"
@@ -264,7 +264,7 @@ def addTestFlinkUberJarPy(String pyVersion) {
                 "--python_root_dir ${project.rootDir}/sdks/python",
                 "--python_version ${pyVersion}",
                 "--python_container_image ${project.docker_image_default_repo_root}/"
-                        + ${project.docker_image_default_repo_prefix}
+                        + "${project.docker_image_default_repo_prefix}"
                         + "python${pyVersion}_sdk:${project.sdk_version}",
         ]
         args "-c", "../../job-server/test_flink_uber_jar.sh ${options.join(' ')}"

diff --git a/runners/spark/job-server/build.gradle b/runners/spark/job-server/build.gradle
@@ -166,7 +166,7 @@ def addTestJavaJarCreator(String pyVersion) {
                 "--python_root_dir ${project.rootDir}/sdks/python",
                 "--python_version ${pyVersion}",
                 "--python_container_image ${project.docker_image_default_repo_root}/"
-                        + ${project.docker_image_default_repo_prefix}
+                        + "${project.docker_image_default_repo_prefix}"
                         + "python${pyVersion}_sdk:${project.sdk_version}",
         ]
         args "-c", "../../portability/test_pipeline_jar.sh ${options.join(' ')}"