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 413683507 [KYUUBI #5300] Batch v2 should not update kyuubi_instance
when open session
413683507 is described below
commit 413683507079f8f97217e8099177f0b16bc9192d
Author: zwangsheng <[email protected]>
AuthorDate: Mon Sep 18 16:00:21 2023 +0800
[KYUUBI #5300] Batch v2 should not update kyuubi_instance when open session
### _Why are the changes needed?_
See more in close #5300
Remove update metadata kyuubi_instance, when open session under batch v2
implementation.
### _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/contributing/code/testing.html#running-tests)
locally before make a pull request
### _Was this patch authored or co-authored using generative AI tooling?_
No
Closes #5301 from zwangsheng/server/v2_should_not_update_connect_url.
Closes #5300
0a67bcda1 [zwangsheng] [V2][REST] Not update kyuubi instace when open
session
Authored-by: zwangsheng <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
---
.../src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala | 1 -
1 file changed, 1 deletion(-)
diff --git
a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala
b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala
index c8563bca1..e10230ebf 100644
---
a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala
+++
b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSession.scala
@@ -156,7 +156,6 @@ class KyuubiBatchSession(
// new batch job created using batch impl v2
val metadataToUpdate = Metadata(
identifier = initialMetadata.identifier,
- kyuubiInstance = connectionUrl,
requestName = name.orNull,
requestConf = optimizedConf ++ kubernetesInfo, // save the
kubernetes info
clusterManager = batchJobSubmissionOp.builder.clusterManager())
