From 54beb3b2d1542d65872fc752c0116b31722db2cf Mon Sep 17 00:00:00 2001 From: tjq Date: Fri, 27 Jan 2023 11:22:16 +0800 Subject: [PATCH] feat: optimize container service --- .../powerjob/server/core/container/ContainerService.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/container/ContainerService.java b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/container/ContainerService.java index 5af8d0b3..35de0310 100644 --- a/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/container/ContainerService.java +++ b/powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/container/ContainerService.java @@ -248,6 +248,7 @@ public class ContainerService { container.setGmtModified(now); container.setLastDeployTime(now); containerInfoRepository.saveAndFlush(container); + remote.sendText(String.format("SYSTEM: update current container version=%s successfully!", container.getVersion())); // 开始部署（需要分批进行） final List allAliveWorkers = workerClusterQueryService.getAllAliveWorkers(container.getAppId()); @@ -420,7 +421,10 @@ public class ContainerService { FileUtils.copyFile(jarWithDependency, 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); }