diff --git a/.github/workflows/master.yml b/.github/workflows/master.yml
index 501f3c3d871..37a282558bb 100644
--- a/.github/workflows/master.yml
+++ b/.github/workflows/master.yml
@@ -191,6 +191,7 @@ jobs:
- '1.16'
- '1.17'
- '1.18'
+ - '1.19'
flink-archive: [ "" ]
comment: [ "normal" ]
include:
@@ -202,6 +203,10 @@ jobs:
flink: '1.17'
flink-archive: '-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.18.1 -Dflink.archive.name=flink-1.18.1-bin-scala_2.12.tgz'
comment: 'verify-on-flink-1.18-binary'
+ - java: 8
+ flink: '1.17'
+ flink-archive: '-Dflink.archive.mirror=https://dist.apache.org/repos/dist/dev/flink/flink-1.19.0-rc2/ -Dflink.archive.name=flink-1.19.0-bin-scala_2.12.tgz'
+ comment: 'verify-on-flink-1.19-binary'
steps:
- uses: actions/checkout@v4
- name: Free up disk space
diff --git a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala
index 06165272dd6..f746df1644b 100644
--- a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala
+++ b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala
@@ -48,7 +48,8 @@ object FlinkEngineUtils extends Logging {
val EMBEDDED_MODE_CLIENT_OPTIONS: Options = getEmbeddedModeClientOptions(new Options)
- private def SUPPORTED_FLINK_VERSIONS = Set("1.16", "1.17", "1.18").map(SemanticVersion.apply)
+ private def SUPPORTED_FLINK_VERSIONS =
+ Set("1.16", "1.17", "1.18", "1.19").map(SemanticVersion.apply)
val FLINK_RUNTIME_VERSION: SemanticVersion = SemanticVersion(EnvironmentInformation.getVersion)
diff --git a/pom.xml b/pom.xml
index b70d5310acb..d575be9382a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2328,6 +2328,25 @@
+
+ flink-1.19
+
+ 1.19.0
+
+
+
+
+ true
+
+
+ true
+
+ Apache Flink 1.19.0 Staging Repository
+ https://repository.apache.org/content/repositories/orgapacheflink-1709/
+
+
+
+
zookeeper-3.6