summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorzhanghongqing <[email protected]>2024-11-14 10:09:01 +0800
committerzhanghongqing <[email protected]>2024-11-14 10:09:01 +0800
commit4c50156195d10cb15e5ba4de6d84de4718c7d0bc (patch)
tree4fe6e63d38bf70a10a2175cb5023f68f79e3770b
parent9270172b6c4e6d5c24d5ee9965bfe8570195682d (diff)
[修改] 修改查询存储配额默认时间develop
-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();