[incubator-kyuubi] branch master updated: [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 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 26b78f5c1 [KYUUBI #3604] Propagate HADOOP_PROXY_USER on launching 
Flink engine
26b78f5c1 is described below

commit 26b78f5c1fb02b9e6bdce96b633bacddb43c229f
Author: dongkelun <dongkelu...@inspur.com>
AuthorDate: Wed Oct 12 15:40:23 2022 +0800

    [KYUUBI #3604] Propagate HADOOP_PROXY_USER on launching Flink engine
    
    ### _Why are the changes needed?_
    
    ### _How was this patch tested?_
    - [ ] Add some test cases that check the changes thoroughly including 
negative and positive cases if possible
    
    - [ ] Add screenshots for manual tests if appropriate
    
    - [ ] [Run 
test](https://kyuubi.apache.org/docs/latest/develop_tools/testing.html#running-tests)
 locally before make a pull request
    
    Closes #3604 from dongkelun/flink-proxy-user.
    
    Closes #3604
    
    e56daea9 [dongkelun] Move HADOOP_PROXY_USER to env of FlinkProcessBuilder
    c6127d48 [dongkelun] Move HADOOP_PROXY_USER to conf of FlinkProcessBuilder
    f5731b2e [dongkelun] Enable Flink to proxy other kerberos users
    
    Authored-by: dongkelun <dongkelu...@inspur.com>
    Signed-off-by: Cheng Pan <cheng...@apache.org>
---
 .../scala/org/apache/kyuubi/engine/flink/FlinkProcessBuilder.scala    | 4 ++++
 1 file changed, 4 insertions(+)

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 f3a7fd480..d30397039 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
@@ -55,6 +55,9 @@ 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]()
@@ -131,4 +134,5 @@ 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"
 }