[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_liu@trip.com>
Signed-off-by: Cheng Pan <chengpan@apache.org>
This commit is contained in:
df_liu 2023-02-09 20:10:13 +08:00 committed by Cheng Pan
parent 5cd33a0e3c
commit b47f0890e1
No known key found for this signature in database
GPG Key ID: 8001952629BCC75D
3 changed files with 3 additions and 2 deletions

View File

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

View File

@ -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"))
}
}

View File

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