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 2024/05/14 20:30:49 UTC
(beam) branch master updated: Fix postrelease revert leftover (#31292)
This is an automated email from the ASF dual-hosted git repository.
yhu 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 54db453b032 Fix postrelease revert leftover (#31292)
54db453b032 is described below
commit 54db453b032bc3e4827fd8d59aa600cba9dd111d
Author: Yi Hu <ya...@google.com>
AuthorDate: Tue May 14 16:30:42 2024 -0400
Fix postrelease revert leftover (#31292)
---
release/build.gradle.kts | 2 +-
runners/flink/flink_runner.gradle | 8 ++++++--
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/release/build.gradle.kts b/release/build.gradle.kts
index ca9982806b9..4e4586f666f 100644
--- a/release/build.gradle.kts
+++ b/release/build.gradle.kts
@@ -39,7 +39,7 @@ task("runJavaExamplesValidationTask") {
dependsOn(":runners:direct-java:runQuickstartJavaDirect")
dependsOn(":runners:google-cloud-dataflow-java:runQuickstartJavaDataflow")
dependsOn(":runners:spark:3:runQuickstartJavaSpark")
- dependsOn(":runners:flink:1.18:runQuickstartJavaFlinkLocal")
+ dependsOn(":runners:flink:1.17:runQuickstartJavaFlinkLocal")
dependsOn(":runners:direct-java:runMobileGamingJavaDirect")
dependsOn(":runners:google-cloud-dataflow-java:runMobileGamingJavaDataflow")
dependsOn(":runners:twister2:runQuickstartJavaTwister2")
diff --git a/runners/flink/flink_runner.gradle b/runners/flink/flink_runner.gradle
index 3965ab3b1ba..da3dbe08b50 100644
--- a/runners/flink/flink_runner.gradle
+++ b/runners/flink/flink_runner.gradle
@@ -376,8 +376,12 @@ tasks.register("validatesRunnerSickbay", Test) {
}
}
-// Generates :runners:flink:1.17:runQuickstartJavaFlinkLocal
-createJavaExamplesArchetypeValidationTask(type: 'Quickstart', runner: 'FlinkLocal')
+if (project.ext.flink_major == project.ext.latestFlinkVersion) {
+ // TODO(yathu) support running validation on all supported Flink versions
+ // currently maven-archetype Flink profile pinned to single Flink version
+ // Generates :runners:flink:<latestFlinkVersion>:runQuickstartJavaFlinkLocal
+ createJavaExamplesArchetypeValidationTask(type: 'Quickstart', runner: 'FlinkLocal')
+}
tasks.register("examplesIntegrationTest", Test) {
group = "Verification"