[KYUUBI apache#6134] Support Flink 1.19

beryllw · Mar 7, 2024 · b93744d · b93744d
1 parent 8cc9b98
commit b93744d
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 1 deletion.
diff --git 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/...ubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala b/...ubi-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
@@ -2328,6 +2328,25 @@
             </properties>
         </profile>
 
+        <profile>
+            <id>flink-1.19</id>
+            <properties>
+                <flink.version>1.19.0</flink.version>
+            </properties>
+            <repositories>
+                <repository>
+                    <releases>
+                        <enabled>true</enabled>
+                    </releases>
+                    <snapshots>
+                        <enabled>true</enabled>
+                    </snapshots>
+                    <id>Apache Flink 1.19.0 Staging Repository</id>
+                    <url>https://repository.apache.org/content/repositories/orgapacheflink-1709/</url>
+                </repository>
+            </repositories>
+        </profile>
+
         <profile>
             <id>zookeeper-3.6</id>
             <properties>