[kyuubi] branch branch-1.7 updated: Revert "[KYUUBI #3604] Propagate HADOOP_PROXY_USER on launching Flink engine"

[chengpan]

This is an automated email from the ASF dual-hosted git repository.

chengpan pushed a commit to branch branch-1.7
in repository https://gitbox.apache.org/repos/asf/kyuubi.git


The following commit(s) were added to refs/heads/branch-1.7 by this push:
     new 2b03da7d8 Revert "[KYUUBI #3604] Propagate HADOOP_PROXY_USER on 
launching Flink engine"
2b03da7d8 is described below

commit 2b03da7d8a5bed5928651ba635a44547a72f9a33
Author: Cheng Pan <cheng...@apache.org>
AuthorDate: Wed Apr 26 17:42:40 2023 +0800

    Revert "[KYUUBI #3604] Propagate HADOOP_PROXY_USER on launching Flink 
engine"
    
    This reverts commit 26b78f5c1fb02b9e6bdce96b633bacddb43c229f.
---
 .../scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilder.scala    | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilder.scala
 
b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilder.scala
index b8146c4d2..d67d13d51 100644
--- 
a/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilder.scala
+++ 
b/kyuubi-server/src/main/scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilder.scala
@@ -54,9 +54,6 @@ class FlinkProcessBuilder(
 
   override protected def mainClass: String = 
"org.apache.kyuubi.engine.flink.FlinkSQLEngine"
 
-  override def env: Map[String, String] = conf.getEnvs +
-    (FLINK_PROXY_USER_KEY -> proxyUser)
-
   override protected val commands: Array[String] = {
     KyuubiApplicationManager.tagApplication(engineRefId, shortName, 
clusterManager(), conf)
     val buffer = new ArrayBuffer[String]()
@@ -133,5 +130,4 @@ object FlinkProcessBuilder {
   final val APP_KEY = "yarn.application.name"
   final val TAG_KEY = "yarn.tags"
   final val FLINK_HADOOP_CLASSPATH_KEY = "FLINK_HADOOP_CLASSPATH"
-  final val FLINK_PROXY_USER_KEY = "HADOOP_PROXY_USER"
 }