[hotfix] upload file oom bug fixed. (apache#693)

* [hotfix] upload file oom bug fixed.

Author: wolfboys

streamx-console/streamx-console-service/src/main/java/com/streamxhub/streamx/console/core/entity/Project.java

@@ -149,8 +149,8 @@ public File getGitRepository() {
 
     @JsonIgnore
     public void delete() throws IOException {
-        File file = getGitRepository();
-        FileUtils.deleteDirectory(file);
+        FileUtils.deleteDirectory(getAppSource());
+        FileUtils.deleteDirectory(getDistHome());
     }
 
     @JsonIgnore
@@ -212,8 +212,7 @@ public boolean isCloned() {
      */
     public void cleanCloned() throws IOException {
         if (isCloned()) {
-            FileUtils.deleteDirectory(getAppSource());
-            FileUtils.deleteDirectory(getDistHome());
+            this.delete();
         }
     }
 

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

@@ -252,7 +252,7 @@ public Map<String, Serializable> dashboard() {
             }
         }
 
-        // mergee metrics from flink kubernetes cluster
+        // merge metrics from flink kubernetes cluster
         FlinkMetricCV k8sMetric = k8sFlinkTrkMonitor.getAccClusterMetrics();
         totalJmMemory += k8sMetric.totalJmMemory();
         totalTmMemory += k8sMetric.totalTmMemory();
@@ -288,13 +288,13 @@ public void tailMvnDownloading(Long id) {
     @Override
     public String upload(MultipartFile file) throws Exception {
         String temp = WebUtils.getAppDir("temp");
-        File saveFile = new File(temp, file.getOriginalFilename());
+        File saveFile = new File(temp, Objects.requireNonNull(file.getOriginalFilename()));
         // delete when exists
         if (saveFile.exists()) {
             saveFile.delete();
         }
         // save file to temp dir
-        FileUtils.writeByteArrayToFile(saveFile, file.getBytes());
+        file.transferTo(saveFile);
         return saveFile.getAbsolutePath();
     }
 

streamx-console/streamx-console-service/src/main/resources/application.yml

@@ -19,8 +19,8 @@ spring:
   servlet:
     multipart:
       enabled: true
-      max-file-size: 200MB
-      max-request-size: 200MB
+      max-file-size: 500MB
+      max-request-size: 500MB
   datasource:
     dynamic:
       # 是否开启 SQL日志输出，生产环境建议关闭，有性能损耗