You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2024/09/14 05:57:23 UTC
(incubator-streampark) branch dev updated: should setJarCheckSum when update application and JarCheckSum change (#4059)
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 <10...@users.noreply.github.com>
AuthorDate: Sat Sep 14 13:57:19 2024 +0800
should setJarCheckSum when update application and JarCheckSum change (#4059)
Co-authored-by: xieyi01 <xi...@rd.netease.com>
---
.../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);