This is an automated email from the ASF dual-hosted git repository.
chengpan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kyuubi.git
The following commit(s) were added to refs/heads/master by this push:
new ae467c2b4 [KYUUBI #6557] Support Flink 1.20
ae467c2b4 is described below
commit ae467c2b4efe1785c622f76d9b9ba2041f6b28e5
Author: Cheng Pan <[email protected]>
AuthorDate: Mon Aug 5 22:57:39 2024 +0800
[KYUUBI #6557] Support Flink 1.20
# :mag: Description
Flink 1.20 is out, [Release
Note](https://nightlies.apache.org/flink/flink-docs-release-1.20/release-notes/flink-1.20/)
## Types of changes :bookmark:
- [ ] Bugfix (non-breaking change which fixes an issue)
- [x] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing
functionality to change)
## Test Plan ๐งช
CI is updated to cover Flink 1.20
---
# Checklist ๐
- [x] This patch was not authored or co-authored using [Generative
Tooling](https://www.apache.org/legal/generative-tooling.html)
**Be nice. Be informative.**
Closes #6557 from pan3793/flink-1.20.
Closes #6557
a414094b9 [Cheng Pan] remove rc
8ee4cf5cd [Cheng Pan] fix url
fbaf66071 [Cheng Pan] docs
ddbd10ffe [Cheng Pan] Support Flink 1.20
Authored-by: Cheng Pan <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
---
.github/workflows/master.yml | 5 +++++
docs/quick_start/quick_start.rst | 2 +-
.../scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala | 2 +-
pom.xml | 7 +++++++
4 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/.github/workflows/master.yml b/.github/workflows/master.yml
index 4e2d329b4..cd2a03a94 100644
--- a/.github/workflows/master.yml
+++ b/.github/workflows/master.yml
@@ -250,6 +250,7 @@ jobs:
- '1.17'
- '1.18'
- '1.19'
+ - '1.20'
flink-archive: [ "" ]
comment: [ "normal" ]
include:
@@ -261,6 +262,10 @@ jobs:
flink: '1.17'
flink-archive:
'-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.19.1
-Dflink.archive.name=flink-1.19.1-bin-scala_2.12.tgz'
comment: 'verify-on-flink-1.19-binary'
+ - java: 8
+ flink: '1.17'
+ flink-archive:
'-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.20.0
-Dflink.archive.name=flink-1.20.0-bin-scala_2.12.tgz'
+ comment: 'verify-on-flink-1.20-binary'
steps:
- uses: actions/checkout@v4
- name: Free up disk space
diff --git a/docs/quick_start/quick_start.rst b/docs/quick_start/quick_start.rst
index 57f63b9c7..76139dd96 100644
--- a/docs/quick_start/quick_start.rst
+++ b/docs/quick_start/quick_start.rst
@@ -44,7 +44,7 @@ pre-installed and the ``JAVA_HOME`` is correctly set to each
component.
Engine lib - Kyuubi Engine
Beeline - Kyuubi Beeline
**Spark** Engine 3.2 to 3.5, 4.0 A Spark distribution
- **Flink** Engine 1.17 to 1.19 A Flink distribution
+ **Flink** Engine 1.17 to 1.20 A Flink distribution
**Trino** Engine N/A A Trino cluster allows to
access via trino-client v411
**Doris** Engine N/A A Doris cluster
**Hive** Engine - 2.1-cdh6/2.3/3.1 - A Hive distribution
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 2865dba53..4293ef19f 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
@@ -46,7 +46,7 @@ object FlinkEngineUtils extends Logging {
val EMBEDDED_MODE_CLIENT_OPTIONS: Options = getEmbeddedModeClientOptions(new
Options)
private def SUPPORTED_FLINK_VERSIONS =
- Set("1.17", "1.18", "1.19").map(SemanticVersion.apply)
+ Set("1.17", "1.18", "1.19", "1.20").map(SemanticVersion.apply)
val FLINK_RUNTIME_VERSION: SemanticVersion =
SemanticVersion(EnvironmentInformation.getVersion)
diff --git a/pom.xml b/pom.xml
index aea5fa14e..b853343b0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2086,6 +2086,13 @@
</properties>
</profile>
+ <profile>
+ <id>flink-1.20</id>
+ <properties>
+ <flink.version>1.20.0</flink.version>
+ </properties>
+ </profile>
+
<profile>
<id>zookeeper-3.6</id>
<properties>
