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); }