File tree Expand file tree Collapse file tree
kyuubi-server/src/main/scala/org/apache/kyuubi/session Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ import com.google.common.annotations.VisibleForTesting
2727import org .apache .kyuubi .KyuubiSQLException
2828import org .apache .kyuubi .client .api .v1 .dto .{Batch , BatchRequest }
2929import org .apache .kyuubi .client .util .BatchUtils .KYUUBI_BATCH_ID_KEY
30- import org .apache .kyuubi .config .KyuubiConf
30+ import org .apache .kyuubi .config .{ KyuubiConf , KyuubiReservedKeys }
3131import org .apache .kyuubi .config .KyuubiConf ._
3232import org .apache .kyuubi .config .KyuubiReservedKeys .{KYUUBI_BATCH_PRIORITY , KYUUBI_SESSION_REAL_USER_KEY }
3333import org .apache .kyuubi .credentials .HadoopCredentialsManager
@@ -316,7 +316,8 @@ class KyuubiSessionManager private (name: String) extends SessionManager(name) {
316316 metadata.username,
317317 " anonymous" ,
318318 metadata.ipAddress,
319- metadata.requestConf,
319+ metadata.requestConf ++
320+ Map (KyuubiReservedKeys .KYUUBI_SESSION_CONNECTION_URL_KEY -> kyuubiInstance),
320321 metadata.engineType,
321322 Option (metadata.requestName),
322323 metadata.resource,
@@ -347,7 +348,8 @@ class KyuubiSessionManager private (name: String) extends SessionManager(name) {
347348 metadata.username,
348349 " anonymous" ,
349350 metadata.ipAddress,
350- metadata.requestConf,
351+ metadata.requestConf ++
352+ Map (KyuubiReservedKeys .KYUUBI_SESSION_CONNECTION_URL_KEY -> kyuubiInstance),
351353 metadata.engineType,
352354 Option (metadata.requestName),
353355 metadata.resource,
You can’t perform that action at this time.
0 commit comments