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 750ed7271 [KYUUBI #6152] Remove useless variable
750ed7271 is described below
commit 750ed7271d7e71d34f214a046ed5201bc19eeb81
Author: wforget <[email protected]>
AuthorDate: Mon Mar 11 15:22:19 2024 +0800
[KYUUBI #6152] Remove useless variable
# :mag: Description
## Issue References ๐
This pull request fixes #6152
## Describe Your Solution ๐ง
`flinkInternalSession.getSessionConfig` returns a new map, and the
`sessionConfig` variable is never used, so we can remove it.
## Types of changes :bookmark:
- [x] 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 :coffin:
#### Behavior With This Pull Request :tada:
#### 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 #6154 from wForget/KYUUBI-6152.
Closes #6152
ca7153ced [wforget] Remove useless variable
Authored-by: wforget <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
---
.../org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala | 2 --
1 file changed, 2 deletions(-)
diff --git
a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
index 1bb82a0ef..3bcb488e8 100644
---
a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
+++
b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
@@ -61,8 +61,6 @@ class FlinkSQLSessionManager(engineContext: DefaultContext)
.setSessionEndpointVersion(SqlGatewayRestAPIVersion.V1)
.addSessionConfig(mapAsJavaMap(conf))
.build)
- val sessionConfig = flinkInternalSession.getSessionConfig
- sessionConfig.putAll(conf.asJava)
val session = new FlinkSessionImpl(
protocol,
user,