[manager]启动采集任务初始化

2022-02-01 16:57:20 +08:00
parent c65b620a5a
commit 9347097905
4 changed files with 80 additions and 3 deletions
--- a/collector/src/main/java/com/usthe/collector/dispatch/entrance/internal/CollectJobService.java
+++ b/collector/src/main/java/com/usthe/collector/dispatch/entrance/internal/CollectJobService.java
@@ -57,10 +57,12 @@ public class CollectJobService {
     * @return long 任务ID
     */
    public long addAsyncCollectJob(Job job) {
-        long jobId = SnowFlakeIdGenerator.generateId();
-        job.setId(jobId);
+        if (job.getId() == 0L) {
+            long jobId = SnowFlakeIdGenerator.generateId();
+            job.setId(jobId);
+        }
        timerDispatch.addJob(job, null);
-        return jobId;
+        return job.getId();
    }

    /**