You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@livy.apache.org by le...@apache.org on 2023/07/22 03:41:01 UTC
[incubator-livy] branch master updated: LIVY-978: Update the application tag generation logic in Livy (#409)
This is an automated email from the ASF dual-hosted git repository.
leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-livy.git
The following commit(s) were added to refs/heads/master by this push:
new b175ba1b LIVY-978: Update the application tag generation logic in Livy (#409)
b175ba1b is described below
commit b175ba1bd1210e2d1db61bdf19a3dbfc1374dd8c
Author: Asif Khatri <12...@users.noreply.github.com>
AuthorDate: Sat Jul 22 09:10:56 2023 +0530
LIVY-978: Update the application tag generation logic in Livy (#409)
Co-authored-by: Asif Khatri <as...@cloudera.com>
---
server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala | 2 +-
.../scala/org/apache/livy/server/interactive/InteractiveSession.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala b/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala
index 16f9d4d1..8b64a039 100644
--- a/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala
+++ b/server/src/main/scala/org/apache/livy/server/batch/BatchSession.scala
@@ -62,7 +62,7 @@ object BatchSession extends Logging {
proxyUser: Option[String],
sessionStore: SessionStore,
mockApp: Option[SparkApp] = None): BatchSession = {
- val appTag = s"livy-batch-$id-${Random.alphanumeric.take(8).mkString}"
+ val appTag = s"livy-batch-$id-${Random.alphanumeric.take(8).mkString}".toLowerCase()
val impersonatedUser = accessManager.checkImpersonation(proxyUser, owner)
def createSparkApp(s: BatchSession): SparkApp = {
diff --git a/server/src/main/scala/org/apache/livy/server/interactive/InteractiveSession.scala b/server/src/main/scala/org/apache/livy/server/interactive/InteractiveSession.scala
index 59a593f6..bf2db0c0 100644
--- a/server/src/main/scala/org/apache/livy/server/interactive/InteractiveSession.scala
+++ b/server/src/main/scala/org/apache/livy/server/interactive/InteractiveSession.scala
@@ -89,7 +89,7 @@ object InteractiveSession extends Logging {
ttl: Option[String],
mockApp: Option[SparkApp] = None,
mockClient: Option[RSCClient] = None): InteractiveSession = {
- val appTag = s"livy-session-$id-${Random.alphanumeric.take(8).mkString}"
+ val appTag = s"livy-session-$id-${Random.alphanumeric.take(8).mkString}".toLowerCase()
val impersonatedUser = accessManager.checkImpersonation(proxyUser, owner)
val client = mockClient.orElse {