This is an automated email from the ASF dual-hosted git repository.
ulyssesyou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git
The following commit(s) were added to refs/heads/master by this push:
new 450cf69 [KYUUBI #2120] Optimize RenewDelegationToken logs in Spark
engine
450cf69 is described below
commit 450cf69134d9ae5c2a212af5e2ab61eddbf6722a
Author: sychen <[email protected]>
AuthorDate: Mon Mar 14 12:53:38 2022 +0800
[KYUUBI #2120] Optimize RenewDelegationToken logs in Spark engine
### _Why are the changes needed?_
Now Spark supports RenewDelegationToken, but there is no log on the driver
side when it is actually updated.
https://github.com/apache/incubator-kyuubi/issues/2120
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including
negative and positive cases if possible
- [x] Add screenshots for manual tests if appropriate
- [x] [Run
test](https://kyuubi.apache.org/docs/latest/develop_tools/testing.html#running-tests)
locally before make a pull request
Closes #2121 from cxzl25/KYUUBI-2120.
Closes #2120
ef11f062 [sychen] add RenewDelegationToken log
Authored-by: sychen <[email protected]>
Signed-off-by: ulysses-you <[email protected]>
---
.../org/apache/kyuubi/engine/spark/SparkTBinaryFrontendService.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkTBinaryFrontendService.scala
b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkTBinaryFrontendService.scala
index 29693b1..bbc6bfa 100644
---
a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkTBinaryFrontendService.scala
+++
b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkTBinaryFrontendService.scala
@@ -52,6 +52,9 @@ class SparkTBinaryFrontendService(
addHiveToken(hiveTokens, oldCreds, updateCreds)
addOtherTokens(otherTokens, oldCreds, updateCreds)
if (updateCreds.numberOfTokens() > 0) {
+ info("Update delegation tokens. " +
+ s"The number of tokens sent by the server is
${newCreds.numberOfTokens()}. " +
+ s"The actual number of updated tokens is
${updateCreds.numberOfTokens()}.")
SparkContextHelper.updateDelegationTokens(sc, updateCreds)
}
