This is an automated email from the ASF dual-hosted git repository.
ibzib 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 3fa9846 [BEAM-11579] Specify flink_job_server_jar instead of using
default.
new 4e83ac5 Merge pull request #13682 from ibzib/BEAM-11579
3fa9846 is described below
commit 3fa98460d0540997da9027465f599c74ee414449
Author: Kyle Weaver <kcwea...@google.com>
AuthorDate: Wed Jan 6 19:58:13 2021 -0800
[BEAM-11579] Specify flink_job_server_jar instead of using default.
The default reads from pipeline_options.py, which hasn't been updated from
Flink 1.10 to 1.12 yet.
---
sdks/python/test-suites/portable/common.gradle | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/sdks/python/test-suites/portable/common.gradle
b/sdks/python/test-suites/portable/common.gradle
index 2793768..cb1b5ff 100644
--- a/sdks/python/test-suites/portable/common.gradle
+++ b/sdks/python/test-suites/portable/common.gradle
@@ -181,10 +181,17 @@ project.task("postCommitPy${pythonVersionSuffix}IT") {
"apache_beam.io.gcp.tests.xlang_spannerio_it_test",
]
def testOpts = ["--tests=${tests.join(',')}"]
+ def pipelineOpts = [
+ "--runner=FlinkRunner",
+ "--project=apache-beam-testing",
+ "--environment_type=LOOPBACK",
+ "--temp_location=gs://temp-storage-for-end-to-end-tests/temp-it",
+
"--flink_job_server_jar=${project(":runners:flink:${latestFlinkVersion}:job-server").shadowJar.archivePath}",
+ ]
def cmdArgs = mapToArgString([
"test_opts": testOpts,
"suite": "postCommitIT-flink-py${pythonVersionSuffix}",
- "pipeline_opts": "--runner=FlinkRunner
--project=apache-beam-testing --environment_type=LOOPBACK
--temp_location=gs://temp-storage-for-end-to-end-tests/temp-it",
+ "pipeline_opts": pipelineOpts.join(" "),
])
def kafkaJar =
project(":sdks:java:testing:kafka-service:").buildTestKafkaServiceJar.archivePath
exec {
