This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new 16fa673782 Flink: Add support for Flink 2.1.0 follow-up (#14156)
16fa673782 is described below
commit 16fa673782233eb2b692d463deb8be3e52c5f378
Author: Manu Zhang <[email protected]>
AuthorDate: Tue Sep 23 01:58:12 2025 +0800
Flink: Add support for Flink 2.1.0 follow-up (#14156)
---
dev/stage-binaries.sh | 2 +-
jmh.gradle | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/dev/stage-binaries.sh b/dev/stage-binaries.sh
index 2d2e0f2a12..ec3080575b 100755
--- a/dev/stage-binaries.sh
+++ b/dev/stage-binaries.sh
@@ -19,7 +19,7 @@
#
SCALA_VERSION=2.12
-FLINK_VERSIONS=1.19,1.20,2.0
+FLINK_VERSIONS=1.20,2.0,2.1
SPARK_VERSIONS=3.4,3.5,4.0
KAFKA_VERSIONS=3
diff --git a/jmh.gradle b/jmh.gradle
index 7f3bc0deaf..57efb3821d 100644
--- a/jmh.gradle
+++ b/jmh.gradle
@@ -26,10 +26,6 @@ def sparkVersions = (System.getProperty("sparkVersions") !=
null ? System.getPro
def scalaVersion = System.getProperty("scalaVersion") != null ?
System.getProperty("scalaVersion") : System.getProperty("defaultScalaVersion")
def jmhProjects = [project(":iceberg-core"), project(":iceberg-data")]
-if (flinkVersions.contains("1.19")) {
- jmhProjects.add(project(":iceberg-flink:iceberg-flink-1.19"))
-}
-
if (flinkVersions.contains("1.20")) {
jmhProjects.add(project(":iceberg-flink:iceberg-flink-1.20"))
}
@@ -38,6 +34,10 @@ if (flinkVersions.contains("2.0")) {
jmhProjects.add(project(":iceberg-flink:iceberg-flink-2.0"))
}
+if (flinkVersions.contains("2.1")) {
+ jmhProjects.add(project(":iceberg-flink:iceberg-flink-2.1"))
+}
+
if (sparkVersions.contains("3.4")) {
jmhProjects.add(project(":iceberg-spark:iceberg-spark-3.4_${scalaVersion}"))
jmhProjects.add(project(":iceberg-spark:iceberg-spark-extensions-3.4_${scalaVersion}"))
