Fix issue If the submission user of Azkaban is empty, modify the submission user to a proxy user

close #7

Author: liuyou2

plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisJob.java

@@ -19,6 +19,7 @@
 
 import com.webank.wedatasphere.dss.linkis.node.execution.job.AbstractAppJointLinkisJob;
 import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
+import org.apache.commons.lang.StringUtils;
 
 
 /**
@@ -29,6 +30,9 @@ public class AzkabanAppJointLinkisJob extends AbstractAppJointLinkisJob {
 
     @Override
     public String getSubmitUser() {
+        if (StringUtils.isEmpty(getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER))){
+            return getJobProps().get(LinkisJobTypeConf.PROXY_USER);
+        }
         return getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER);
     }
 

plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisJob.java

@@ -19,6 +19,7 @@
 
 import com.webank.wedatasphere.dss.linkis.node.execution.job.AbstractCommonLinkisJob;
 import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
+import org.apache.commons.lang.StringUtils;
 
 
 /**
@@ -29,6 +30,9 @@ public class AzkabanCommonLinkisJob extends AbstractCommonLinkisJob {
 
     @Override
     public String getSubmitUser() {
+        if (StringUtils.isEmpty(getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER))){
+            return getJobProps().get(LinkisJobTypeConf.PROXY_USER);
+        }
         return getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER);
     }
 

plugins/azkaban/linkis-jobtype/src/main/resources/assembly.xml

@@ -59,15 +59,6 @@
             <lineEnding>unix</lineEnding>
         </fileSet>
 
-        <fileSet>
-            <directory>${basedir}/target</directory>
-            <includes>
-                <include>*.jar</include>
-            </includes>
-            <fileMode>0777</fileMode>
-            <outputDirectory>/</outputDirectory>
-            <lineEnding>unix</lineEnding>
-        </fileSet>
         <fileSet>
             <directory>${basedir}/bin</directory>
             <includes>