You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2025/10/08 21:18:48 UTC
(beam) branch fix-xvr created (now fb870caf17b)
This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch fix-xvr
in repository https://gitbox.apache.org/repos/asf/beam.git
at fb870caf17b Fix XVR JavaUsingPython tests using dev Beam at expansion
This branch includes the following new commits:
new fb870caf17b Fix XVR JavaUsingPython tests using dev Beam at expansion
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(beam) 01/01: Fix XVR JavaUsingPython tests using dev Beam at expansion
Posted by yh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch fix-xvr
in repository https://gitbox.apache.org/repos/asf/beam.git
commit fb870caf17b7a7bfae7bddeaf58971f15b2605c6
Author: Yi Hu <ya...@google.com>
AuthorDate: Wed Oct 8 17:17:00 2025 -0400
Fix XVR JavaUsingPython tests using dev Beam at expansion
---
runners/flink/job-server/flink_job_server.gradle | 1 +
runners/google-cloud-dataflow-java/build.gradle | 1 +
runners/samza/job-server/build.gradle | 1 +
runners/spark/job-server/spark_job_server.gradle | 1 +
sdks/python/test-suites/direct/xlang/build.gradle | 1 +
5 files changed, 5 insertions(+)
diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle
index 90890a7d585..d8a818ff84c 100644
--- a/runners/flink/job-server/flink_job_server.gradle
+++ b/runners/flink/job-server/flink_job_server.gradle
@@ -269,6 +269,7 @@ createCrossLanguageValidatesRunnerTask(
"--environmentCacheMillis=10000",
"--experiments=beam_fn_api",
"--parallelism=2",
+ "--customBeamRequirement=${project.project(":sdks:python").projectDir}/build/apache-beam.tar.gz",
],
goScriptOptions: [
"--runner flink",
diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle
index 85f8b583c34..8729bc2032c 100644
--- a/runners/google-cloud-dataflow-java/build.gradle
+++ b/runners/google-cloud-dataflow-java/build.gradle
@@ -486,6 +486,7 @@ createCrossLanguageValidatesRunnerTask(
"--tempRoot=${dataflowValidatesTempRoot}",
"--sdkContainerImage=${dockerJavaImageContainer}:${dockerTag}",
"--sdkHarnessContainerImageOverrides=.*python.*,${dockerPythonImageContainer}:${dockerTag}",
+ "--customBeamRequirement=${project.project(":sdks:python").projectDir}/build/apache-beam.tar.gz",
],
pytestOptions: [
"--capture=no",
diff --git a/runners/samza/job-server/build.gradle b/runners/samza/job-server/build.gradle
index 05f6de39254..7ffb2becd6d 100644
--- a/runners/samza/job-server/build.gradle
+++ b/runners/samza/job-server/build.gradle
@@ -243,6 +243,7 @@ createCrossLanguageValidatesRunnerTask(
"--jobEndpoint=localhost:${jobPort}",
"--environmentCacheMillis=10000",
"--experiments=beam_fn_api",
+ "--customBeamRequirement=${project.project(":sdks:python").projectDir}/build/apache-beam.tar.gz",
],
goScriptOptions: [
"--runner samza",
diff --git a/runners/spark/job-server/spark_job_server.gradle b/runners/spark/job-server/spark_job_server.gradle
index 90109598ed6..7e2deaf6e39 100644
--- a/runners/spark/job-server/spark_job_server.gradle
+++ b/runners/spark/job-server/spark_job_server.gradle
@@ -294,6 +294,7 @@ createCrossLanguageValidatesRunnerTask(
"--jobEndpoint=localhost:${jobPort}",
"--environmentCacheMillis=10000",
"--experiments=beam_fn_api",
+ "--customBeamRequirement=${project.project(":sdks:python").projectDir}/build/apache-beam.tar.gz",
],
goScriptOptions: [
"--runner spark",
diff --git a/sdks/python/test-suites/direct/xlang/build.gradle b/sdks/python/test-suites/direct/xlang/build.gradle
index 3003329aef5..cd44c9634f7 100644
--- a/sdks/python/test-suites/direct/xlang/build.gradle
+++ b/sdks/python/test-suites/direct/xlang/build.gradle
@@ -62,6 +62,7 @@ createCrossLanguageValidatesRunnerTask(
"--jobEndpoint=localhost:${jobPort}",
"--environmentCacheMillis=10000",
"--experiments=beam_fn_api",
+ "--customBeamRequirement=${project.project(":sdks:python").projectDir}/build/apache-beam.tar.gz"
],
goScriptOptions: [
"--runner portable",