From 80c7c982a1e758d5af8d74dc5827c8a465757fad Mon Sep 17 00:00:00 2001 From: andylau-55 Date: Fri, 10 Jan 2025 15:39:57 +0800 Subject: [PATCH] mvn spotless:apply #andy --- .../task/async/builder/KagAlignmentAsyncTask.java | 2 +- .../task/async/builder/KagExtractorAsyncTask.java | 2 +- .../task/async/builder/KagSplitterAsyncTask.java | 2 +- .../task/async/builder/KagVectorizerAsyncTask.java | 10 ++++++---- .../service/task/async/builder/KagWriterAsyncTask.java | 2 +- 5 files changed, 10 insertions(+), 8 deletions(-) diff --git a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagAlignmentAsyncTask.java b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagAlignmentAsyncTask.java index 96ad8d13e..0b5a6c402 100644 --- a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagAlignmentAsyncTask.java +++ b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagAlignmentAsyncTask.java @@ -93,7 +93,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res SchedulerTask task = memoryTaskServer.getTask(resource); SchedulerTask schedulerTask = context.getTask(); if (task == null) { - context.addTraceLog("Splitter task not found, recreate it"); + context.addTraceLog("Splitter task not found, recreating……"); submit(context); return SchedulerEnum.TaskStatus.RUNNING; } diff --git a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagExtractorAsyncTask.java b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagExtractorAsyncTask.java index 11483aa20..2cae28150 100644 --- a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagExtractorAsyncTask.java +++ b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagExtractorAsyncTask.java @@ -129,7 +129,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res SchedulerTask task = memoryTaskServer.getTask(resource); SchedulerTask schedulerTask = context.getTask(); if (task == null) { - context.addTraceLog("Extractor task not found, recreate it"); + context.addTraceLog("Extractor task not found, recreating……"); submit(context); return SchedulerEnum.TaskStatus.RUNNING; } diff --git a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagSplitterAsyncTask.java b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagSplitterAsyncTask.java index caaa65d62..e1b742e67 100644 --- a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagSplitterAsyncTask.java +++ b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagSplitterAsyncTask.java @@ -94,7 +94,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res SchedulerTask task = memoryTaskServer.getTask(resource); SchedulerTask schedulerTask = context.getTask(); if (task == null) { - context.addTraceLog("Splitter task not found, recreate it"); + context.addTraceLog("Splitter task not found, recreating……"); submit(context); return SchedulerEnum.TaskStatus.RUNNING; } diff --git a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagVectorizerAsyncTask.java b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagVectorizerAsyncTask.java index f8ae73671..46c07ab37 100644 --- a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagVectorizerAsyncTask.java +++ b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagVectorizerAsyncTask.java @@ -12,9 +12,14 @@ */ package com.antgroup.openspg.server.core.scheduler.service.task.async.builder; +import java.util.List; +import java.util.Map; +import java.util.concurrent.atomic.AtomicLong; + import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; + import com.antgroup.openspg.builder.model.record.SubGraphRecord; import com.antgroup.openspg.cloudext.interfaces.objectstorage.ObjectStorageClient; import com.antgroup.openspg.cloudext.interfaces.objectstorage.ObjectStorageClientDriverManager; @@ -39,9 +44,6 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import java.util.List; -import java.util.Map; -import java.util.concurrent.atomic.AtomicLong; import org.apache.commons.collections4.CollectionUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -98,7 +100,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res SchedulerTask task = memoryTaskServer.getTask(resource); SchedulerTask schedulerTask = context.getTask(); if (task == null) { - context.addTraceLog("Vectorizer task not found, recreate it"); + context.addTraceLog("Vectorizer task not found, recreating……"); submit(context); return SchedulerEnum.TaskStatus.RUNNING; } diff --git a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagWriterAsyncTask.java b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagWriterAsyncTask.java index 1ff8d1e15..15f917e75 100644 --- a/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagWriterAsyncTask.java +++ b/server/core/scheduler/service/src/main/java/com/antgroup/openspg/server/core/scheduler/service/task/async/builder/KagWriterAsyncTask.java @@ -96,7 +96,7 @@ public SchedulerEnum.TaskStatus getStatus(TaskExecuteContext context, String res SchedulerTask task = memoryTaskServer.getTask(resource); SchedulerTask schedulerTask = context.getTask(); if (task == null) { - context.addTraceLog("Writer task not found, recreate it"); + context.addTraceLog("Writer task not found, recreating……"); submit(context); return SchedulerEnum.TaskStatus.RUNNING; }