You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kyuubi.apache.org by ch...@apache.org on 2023/02/09 12:10:24 UTC
[kyuubi] branch master updated: [KYUUBI #4250] Bump Flink to 1.16.1
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 b47f0890e [KYUUBI #4250] Bump Flink to 1.16.1
b47f0890e is described below
commit b47f0890e1cdeecbf0a54988e912d6640fdd2720
Author: df_liu <df...@trip.com>
AuthorDate: Thu Feb 9 20:10:13 2023 +0800
[KYUUBI #4250] Bump Flink to 1.16.1
### _Why are the changes needed?_
close #4250
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible
- [ ] Add screenshots for manual tests if appropriate
- [ ] [Run test](https://kyuubi.readthedocs.io/en/master/develop_tools/testing.html#running-tests) locally before make a pull request
Closes #4275 from df-Liu/fix_4250.
Closes #4250
723c4b745 [df_liu] [KYUUBI #4250] fix 1.16.1
0e151a408 [df_liu] [KYUUBI #4250] Bump Flink 1.16.1
Authored-by: df_liu <df...@trip.com>
Signed-off-by: Cheng Pan <ch...@apache.org>
---
.github/workflows/master.yml | 2 +-
.../org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala | 1 +
pom.xml | 2 +-
3 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/.github/workflows/master.yml b/.github/workflows/master.yml
index 7a58a5d08..d5494a42c 100644
--- a/.github/workflows/master.yml
+++ b/.github/workflows/master.yml
@@ -162,7 +162,7 @@ jobs:
comment: 'verify-on-flink-1.14-binary'
- java: 8
flink: '1.15'
- flink-archive: '-Dflink.archive.mirror=https://archive.apache.org/dist/flink/flink-1.16.0 -Dflink.archive.name=flink-1.16.0-bin-scala_2.12.tgz'
+ 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'
comment: 'verify-on-flink-1.16-binary'
steps:
- uses: actions/checkout@v3
diff --git a/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala b/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala
index c75124c39..d0522d3ea 100644
--- a/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala
+++ b/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala
@@ -903,6 +903,7 @@ class FlinkOperationSuite extends WithFlinkSQLEngine with HiveJDBCTestHelper {
statement.getConnection.setCatalog("cat_a")
val changedCatalog = statement.getConnection.getCatalog
assert(changedCatalog == "cat_a")
+ statement.getConnection.setCatalog("default_catalog")
assert(statement.execute("drop catalog cat_a"))
}
}
diff --git a/pom.xml b/pom.xml
index 15d425dbb..b57324989 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2344,7 +2344,7 @@
<profile>
<id>flink-1.16</id>
<properties>
- <flink.version>1.16.0</flink.version>
+ <flink.version>1.16.1</flink.version>
<flink.module.scala.suffix></flink.module.scala.suffix>
</properties>
</profile>