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 {