diff --git a/dev/stage-binaries.sh b/dev/stage-binaries.sh
index 2d2e0f2a1202..ec3080575b86 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 7f3bc0deafd2..57efb3821d8f 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}"))