diff options
Diffstat (limited to 'galaxy-job-executor/src')
| -rw-r--r-- | galaxy-job-executor/src/main/java/com/mesalab/executor/service/StorageQuotaService.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/galaxy-job-executor/src/main/java/com/mesalab/executor/service/StorageQuotaService.java b/galaxy-job-executor/src/main/java/com/mesalab/executor/service/StorageQuotaService.java index 6f64533..e0b0ca9 100644 --- a/galaxy-job-executor/src/main/java/com/mesalab/executor/service/StorageQuotaService.java +++ b/galaxy-job-executor/src/main/java/com/mesalab/executor/service/StorageQuotaService.java @@ -2,6 +2,7 @@ package com.mesalab.executor.service; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.db.handler.BeanListHandler; import cn.hutool.db.handler.NumberHandler; @@ -295,7 +296,7 @@ public class StorageQuotaService { JobResult<SysStorageEvent> jobResult = new JobResult<>(); int failCount = 0; long generatedTime = DateUtil.currentSeconds(); - Long sinceTime = getZkStorageNode(zkNode); + Long sinceTime = ObjectUtil.defaultIfNull(getZkStorageNode(zkNode), generatedTime); for (Map.Entry<String, String> entry : dataCenterMap.entrySet()) { try { String dataCenterHost = entry.getValue(); |
