rename params to support multiple engines

apache · Mar 15, 2024 · f54efdb · f54efdb
1 parent 991f58a
commit f54efdb
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/AdminResource.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/AdminResource.scala
@@ -249,9 +249,9 @@ private[v1] class AdminResource extends ApiRequestContext with Logging {
       @QueryParam("hive.server2.proxy.user") hs2ProxyUser: String,
       @QueryParam("forceKill") @DefaultValue("false") forceKill: Boolean,
       @QueryParam("refId") refId: String,
-      @QueryParam("sparK8Context") sparK8Context: String,
-      @QueryParam("sparK8Namespace") sparK8Namespace: String,
-      @QueryParam("sparkMaster") sparkMaster: String): Response = {
+      @QueryParam("kubernetesContext") kubernetesContext: String,
+      @QueryParam("kubernetesNamespace") kubernetesNamespace: String,
+      @QueryParam("resourceManager") resourceManager: String): Response = {
     val activeProxyUser = Option(kyuubiProxyUser).getOrElse(hs2ProxyUser)
     val userName = if (fe.isAdministrator(fe.getRealUser())) {
       Option(activeProxyUser).getOrElse(fe.getRealUser())
@@ -267,9 +267,9 @@ private[v1] class AdminResource extends ApiRequestContext with Logging {
       }
 
       val applicationManagerInfo = ApplicationManagerInfo(
-        Option(sparkMaster),
-        Option(sparK8Context),
-        Option(sparK8Namespace))
+        Option(resourceManager),
+        Option(kubernetesContext),
+        Option(kubernetesNamespace))
 
       val killMessage = fe.be.sessionManager.asInstanceOf[KyuubiSessionManager]
         .applicationManager.killApplication(applicationManagerInfo, refId)