Skip to content

Commit

Permalink
bugfix counting wrong tasks num of collector (#1265)
Browse files Browse the repository at this point in the history
  • Loading branch information
tomsun28 committed Mar 10, 2024
1 parent 6c203c3 commit 41f5f24
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -369,8 +369,8 @@ public long addAsyncCollectJob(Job job, String collector) {
log.error("there is no collector name: {} online to assign job.", collector);
return jobId;
}
node.getAssignJobs().addPinnedJob(jobId);
}
node.getAssignJobs().addPinnedJob(jobId);
if (CommonConstants.MAIN_COLLECTOR_NODE.equals(node.getIdentity())) {
collectJobService.addAsyncCollectJob(job);
} else {
Expand Down

0 comments on commit 41f5f24

Please sign in to comment.