From d9dd3b259ac1c368a963727b857cfff624d84e87 Mon Sep 17 00:00:00 2001
From: wangminchao <wangminchao@lingxing.com>
Date: Sat, 20 Jan 2024 20:09:26 +0800
Subject: [PATCH] [Fix] Append timestamp suffix for upload jar

---
 .../console/core/service/impl/ApplicationServiceImpl.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
index 1d26029c1c..c04249b4d3 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ApplicationServiceImpl.java
@@ -143,7 +143,6 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.CancellationException;
@@ -315,7 +314,12 @@ public Map<String, Serializable> dashboard(Long teamId) {
   @Override
   public String upload(MultipartFile file) throws Exception {
     File temp = WebUtils.getAppTempDir();
-    String fileName = FilenameUtils.getName(Objects.requireNonNull(file.getOriginalFilename()));
+    String originalFilename = file.getOriginalFilename();
+    String nameWithoutExtension = FilenameUtils.getBaseName(originalFilename);
+    String extension = FilenameUtils.getExtension(originalFilename);
+    // Append timestamp to the original file name
+    String fileName =
+        String.format("%s_%d.%s", nameWithoutExtension, System.currentTimeMillis(), extension);
     File saveFile = new File(temp, fileName);
     // delete when exists
     if (saveFile.exists()) {