From b47f0890e1cdeecbf0a54988e912d6640fdd2720 Mon Sep 17 00:00:00 2001 From: df_liu Date: Thu, 9 Feb 2023 20:10:13 +0800 Subject: [PATCH] [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 Signed-off-by: Cheng Pan --- .github/workflows/master.yml | 2 +- .../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 @@ flink-1.16 - 1.16.0 + 1.16.1