[hotfix] yarn-application mode bug fixed. (apache#779)

Author: wolfboys

README.md

@@ -117,9 +117,7 @@ Our ultimate goal is to build a one-stop big data solution integrating stream pr
 * ...
 
 Thanks to the above excellent open source projects and many outstanding open source projects that are not mentioned, for giving the greatest
-respect, special thanks to [Apache Zeppelin](http://zeppelin.apache.org)
-, [IntelliJ IDEA](https://www.jetbrains.com/idea/), Thanks to the [fire-spark](https://github.com/GuoNingNing/fire-spark) project for the
-early inspiration and help.
+respect,Thanks to [Apache Flink](http://flink.apache.org) for creating a great project!  Thanks to the [Apache Zeppelin](http://zeppelin.apache.org) project for the early inspiration.
 
 ### 🚀 Quick Start
 

README_CN.md

@@ -37,11 +37,9 @@ Make stream processing easier
 
 ## 🚀 什么是StreamX
 
-    大数据技术如今发展的如火如荼，已经呈现百花齐放欣欣向荣的景象，实时处理流域 `Apache Spark` 和 `Apache Flink`
-更是一个伟大的进步，尤其是 `Apache Flink` 被普遍认为是下一代大数据流计算引擎， 我们在使用 `Flink` 时发现从编程模型， 启动配置到运维管理都有很多可以抽象共用的地方， 我们将一些好的经验固化下来并结合业内的最佳实践， 通过不断努力终于诞生了今天的框架
-—— `StreamX`， 项目的初衷是 —— 让 `Flink` 开发更简单， 使用 `StreamX` 开发，可以极大降低学习成本和开发门槛， 让开发者只用关心最核心的业务， `StreamX`
-规范了项目的配置，鼓励函数式编程，定义了最佳的编程方式，提供了一系列开箱即用的 `Connectors` ，标准化了配置、开发、测试、部署、监控、运维的整个过程， 提供 `Scala` 和 `Java` 两套api，
-其最终目的是打造一个一站式大数据平台，流批一体，湖仓一体的解决方案
+实时即未来, 在实时处理流域 `Apache Spark` 和 `Apache Flink` 是一个伟大的进步,尤其是 `Apache Flink` 被普遍认为是下一代大数据流计算引擎, 我们在使用 `Flink` & `Spark` 时发现从编程模型, 参数配置到项目部署, 运维管理都有很多可以抽象共用的地方, 
+我们将一些好的经验固化下来并结合业内的最佳实践, 通过不断努力终于诞生了今天的框架 —— `StreamX`, 项目的初衷是 —— 让流处理更简单, 使用 `StreamX` 开发, 可以极大降低学习成本和开发门槛, 让开发者只用关心最核心的业务, `StreamX` 规范了项目的配置,
+鼓励函数式编程, 定义了最佳的编程方式, 提供了一系列开箱即用的 `Connectors`, 标准化了配置、开发、测试、部署、监控、运维的整个过程, 提供了 Scala/Java 两套 api, 其最终目的是打造一个一站式大数据平台, 流批一体,湖仓一体的解决方案
 
 [![StreamX video](https://user-images.githubusercontent.com/13284744/142747056-d220d69b-7f2a-447d-aeca-bc5435c8e29b.png)](http://assets.streamxhub.com/streamx-video.mp4)
 
@@ -111,9 +109,7 @@ Make stream processing easier
 * [Monaco Editor](https://microsoft.github.io/monaco-editor/)
 * ...
 
-感谢以上优秀的开源项目和很多未提到的优秀开源项目，致以最崇高的敬意，特别感谢[Apache Zeppelin](http://zeppelin.apache.org)
-，[IntelliJ IDEA](https://www.jetbrains.com/idea/)，
-感谢 [fire-spark](https://github.com/GuoNingNing/fire-spark) 项目，早期给予的灵感和帮助， 感谢我老婆在项目开发时给予的支持，悉心照顾我的生活和日常，给予我足够的时间开发这个项目
+感谢以上优秀的开源项目和很多未提到的优秀开源项目，致以最崇高的敬意，感谢 [Apache Flink](http://flink.apache.org) 创造了一个了不起的项目! 感谢 [Apache Zeppelin](http://zeppelin.apache.org) 早期给予的灵感，感谢我老婆在项目开发时给予的支持，悉心照顾我的生活和日常，给予我足够的时间开发这个项目!
 
 ### 🚀 快速上手
 

streamx-console/streamx-console-service/src/main/java/com/streamxhub/streamx/console/core/controller/ApplicationBuildPipelineController.java

@@ -74,7 +74,7 @@ public RestResponse buildApplication(Long appId, boolean forceBuild) {
                 return RestResponse.create().data(false);
             }
             Application app = applicationService.getById(appId);
-            // 检查是否需要走build这一步流程(如:jar和pom发送变化了则需要走build流程,其他普通参数修改了,不需要走build流程)
+            // 检查是否需要走build这一步流程(jar和pom发生变化了则需要走build流程, 其他普通参数修改了,不需要走build流程)
             boolean needBuild = applicationService.checkBuildAndUpdate(app);
             if (!needBuild) {
                 return RestResponse.create().data(true);

streamx-console/streamx-console-service/src/main/java/com/streamxhub/streamx/console/core/service/impl/ApplBuildPipeServiceImpl.java

@@ -184,8 +184,7 @@ public void onStart(PipeSnapshot snapshot) throws Exception {
                     FsOperator fsOperator = app.getFsOperator();
                     fsOperator.delete(appHome);
                     if (app.isUploadJob()) {
-                        File temp = WebUtils.getAppTempDir();
-                        File localJar = new File(temp, app.getJar());
+                        File localJar = new File(WebUtils.getAppTempDir(), app.getJar());
                         // upload jar copy to appHome
                         String uploadJar = appUploads.concat("/").concat(app.getJar());
                         checkOrElseUploadJar(app.getFsOperator(), localJar, uploadJar, appUploads);
@@ -196,12 +195,13 @@ public void onStart(PipeSnapshot snapshot) throws Exception {
                     }
                 } else {
                     if (!app.getDependencyObject().getJar().isEmpty()) {
-                        //copy jar to upload dir
+                        //copy jar to local upload dir
                         for (String jar : app.getDependencyObject().getJar()) {
-                            File jarFile = new File(WebUtils.getAppTempDir(), jar);
-                            assert jarFile.exists();
-                            String uploadJar = appUploads.concat("/").concat(jar);
-                            checkOrElseUploadJar(FsOperator.lfs(), jarFile, uploadJar, appUploads);
+                            File localJar = new File(WebUtils.getAppTempDir(), jar);
+                            assert localJar.exists();
+                            String localUploads = Workspace.local().APP_UPLOADS();
+                            String uploadJar = localUploads.concat("/").concat(jar);
+                            checkOrElseUploadJar(FsOperator.lfs(), localJar, uploadJar, localUploads);
                         }
                     }
                 }