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,

Reply via email to