From 80ab41813a3af3c805fad1241c8ceddb4dd6eebb Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Thu, 17 Nov 2022 17:16:14 -0500 Subject: [PATCH] Attempt to fix Python Flik Example PostCommit * Gradle switch was added in wrong place --- sdks/python/test-suites/portable/common.gradle | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sdks/python/test-suites/portable/common.gradle b/sdks/python/test-suites/portable/common.gradle index 9585d0922046..bd07e9ff5755 100644 --- a/sdks/python/test-suites/portable/common.gradle +++ b/sdks/python/test-suites/portable/common.gradle @@ -236,6 +236,9 @@ project.tasks.register("flinkExamples") { // suppress full __metricscontainers log printed in FlinkPipelineRunner.createPortablePipelineResult '\\"org.apache.beam.runners.flink.FlinkPipelineRunner\\":\\"WARN\\"}' ] + if (project.hasProperty('flinkConfDir')) { + pipelineOpts += ["--flink-conf-dir=${project.property('flinkConfDir')}"] + } def cmdArgs = mapToArgString([ "test_opts": testOpts, "suite": "postCommitExamples-flink-py${pythonVersionSuffix}", @@ -317,9 +320,6 @@ project.tasks.register("postCommitPy${pythonVersionSuffix}IT") { // suppress metric name collision warning logs '\\"org.apache.flink.runtime.metrics.groups\\":\\"ERROR\\"}' ] - if (project.hasProperty('flinkConfDir')) { - pipelineOpts += ["--flink-conf-dir=${project.property('flinkConfDir')}"] - } def cmdArgs = mapToArgString([ "test_opts": testOpts, "suite": "postCommitIT-flink-py${pythonVersionSuffix}",