summaryrefslogtreecommitdiff
path: root/galaxy-job-executor/src
diff options
context:
space:
mode:
Diffstat (limited to 'galaxy-job-executor/src')
-rw-r--r--galaxy-job-executor/src/main/java/com/mesalab/executor/service/StorageQuotaService.java3
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();