apache/kyuubi
1
0
Fork 0
Code Issues Pull Requests Actions 5 Packages Projects Releases Wiki Activity

[KYUUBI #6097][KYUUBI #6098] Upgrade Flink 1.16.3 and 1.18.1

Browse Source 
# 🔍 Description
## Issue References 🔗

This pull request fixes https://github.com/apache/kyuubi/issues/6098, https://github.com/apache/kyuubi/issues/6097
## Describe Your Solution 🔧

Upgrade flink from 1.16.2 to 1.16.3 and 1.18.0 to 1.18.1

## Types of changes 🔖

- [ ] Bugfix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing functionality to change)

## Test Plan 🧪

#### Behavior Without This Pull Request ⚰️

#### Behavior With This Pull Request 🎉

#### Related Unit Tests

---

# 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 #6105 from Deepali1211/master.

Closes #6097

Closes #6098

0d3516b24 [Deepali Gupta] Update flink version
1543443d3 [Deepali Gupta] Update flink version
c95e3bfc0 [Deepali Gupta] Update flink version

Lead-authored-by: Deepali Gupta <g.deepali1211@gmail.com>
Co-authored-by: Deepali Gupta <90255953+Deepali1211@users.noreply.github.com>
Signed-off-by: Cheng Pan <chengpan@apache.org>
This commit is contained in:
Deepali Gupta 2024-02-28 11:08:16 +08:00 committed by Cheng Pan
parent d007d7af10
commit 494eff41f4
No known key found for this signature in database
GPG Key ID: 8001952629BCC75D
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
.github/workflows/master.yml vendored
View File

@ -196,11 +196,11 @@ jobs:
include:
- java: 8
flink: '1.17'
flink-archive: '-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.16.1 -Dflink.archive.name=flink-1.16.1-bin-scala_2.12.tgz'
flink-archive: '-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.16.3 -Dflink.archive.name=flink-1.16.3-bin-scala_2.12.tgz'
comment: 'verify-on-flink-1.16-binary'
- java: 8
flink: '1.17'
flink-archive: '-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.18.0 -Dflink.archive.name=flink-1.18.0-bin-scala_2.12.tgz'
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'
steps:
- uses: actions/checkout@v4

4
kyuubi-server/src/test/scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilderSuite.scala
View File

@ -50,8 +50,8 @@ class FlinkProcessBuilderSuite extends KyuubiFunSuite {
private val tempFlinkHome = Files.createTempDirectory("flink-home").toFile
private val tempOpt =
Files.createDirectories(Paths.get(tempFlinkHome.toPath.toString, "opt")).toFile
Files.createFile(Paths.get(tempOpt.toPath.toString, "flink-sql-client-1.16.1.jar"))
Files.createFile(Paths.get(tempOpt.toPath.toString, "flink-sql-gateway-1.16.1.jar"))
Files.createFile(Paths.get(tempOpt.toPath.toString, "flink-sql-client-1.16.3.jar"))
Files.createFile(Paths.get(tempOpt.toPath.toString, "flink-sql-gateway-1.16.3.jar"))
private val tempUsrLib =
Files.createDirectories(Paths.get(tempFlinkHome.toPath.toString, "usrlib")).toFile
private val tempUdfJar =

4
pom.xml
View File

@ -2335,7 +2335,7 @@
<profile>
<id>flink-1.16</id>
<properties>
<flink.version>1.16.2</flink.version>
<flink.version>1.16.3</flink.version>
</properties>
</profile>
@ -2349,7 +2349,7 @@
<profile>
<id>flink-1.18</id>
<properties>
<flink.version>1.18.0</flink.version>
<flink.version>1.18.1</flink.version>
</properties>
</profile>