third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimize container service

Browse Source
This commit is contained in:
tjq 2023-01-27 11:22:16 +08:00
parent 2bd2ceca8e
commit 54beb3b2d1
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/container/ContainerService.java
View File

@ -248,6 +248,7 @@ public class ContainerService {
container.setGmtModified(now); container.setGmtModified(now);
container.setLastDeployTime(now); container.setLastDeployTime(now);
containerInfoRepository.saveAndFlush(container); containerInfoRepository.saveAndFlush(container);
remote.sendText(String.format("SYSTEM: update current container version=%s successfully!", container.getVersion()));
// 开始部署（需要分批进行） // 开始部署（需要分批进行）
final List<WorkerInfo> allAliveWorkers = workerClusterQueryService.getAllAliveWorkers(container.getAppId()); final List<WorkerInfo> allAliveWorkers = workerClusterQueryService.getAllAliveWorkers(container.getAppId());
@ -420,7 +421,10 @@ public class ContainerService {
FileUtils.copyFile(jarWithDependency, localFile); FileUtils.copyFile(jarWithDependency, localFile);
return localFile; return localFile;
}finally { } catch (Throwable t) {
log.error("[ContainerService] prepareJarFile failed for container: {}", container, t);
remote.sendText("SYSTEM: [ERROR] prepare jar file failed: " + ExceptionUtils.getStackTrace(t));
} finally {
// 删除工作区数据 // 删除工作区数据
FileUtils.forceDelete(workerDir); FileUtils.forceDelete(workerDir);
} }