Skip to content

Commit

Permalink
[KYUUBI #6097][KYUUBI #6098] Upgrade Flink 1.16.3 and 1.18.1
Browse files Browse the repository at this point in the history
# 🔍 Description
## Issue References 🔗

This pull request fixes #6098, #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

0d3516b [Deepali Gupta] Update flink version
1543443 [Deepali Gupta] Update flink version
c95e3bf [Deepali Gupta] Update flink version

Lead-authored-by: Deepali Gupta <[email protected]>
Co-authored-by: Deepali Gupta <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
  • Loading branch information
2 people authored and pan3793 committed Feb 28, 2024
1 parent d007d7a commit 494eff4
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions .github/workflows/master.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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>

Expand All @@ -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>

Expand Down

0 comments on commit 494eff4

Please sign in to comment.