This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new ff882bcd6 should setJarCheckSum when update application and 
JarCheckSum change (#4059)
ff882bcd6 is described below

commit ff882bcd645e30e9d89d52a6734a67f2afc38fbd
Author: Xie Yi <[email protected]>
AuthorDate: Sat Sep 14 13:57:19 2024 +0800

    should setJarCheckSum when update application and JarCheckSum change (#4059)
    
    Co-authored-by: xieyi01 <[email protected]>
---
 .../core/service/application/impl/ApplicationManageServiceImpl.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
index 25cdf6344..6db9f4b28 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/ApplicationManageServiceImpl.java
@@ -492,6 +492,7 @@ public class ApplicationManageServiceImpl extends 
ServiceImpl<ApplicationMapper,
                         long checkSum = 
org.apache.commons.io.FileUtils.checksumCRC32(jarFile);
                         if (!Objects.equals(checkSum, 
application.getJarCheckSum())) {
                             application.setBuild(true);
+                            application.setJarCheckSum(checkSum);
                         }
                     } catch (IOException e) {
                         log.error("Error in checksumCRC32 for {}.", jarFile);

Reply via email to