This is an automated email from the ASF dual-hosted git repository.
gongchao pushed a commit to branch alarm-inhibit
in repository https://gitbox.apache.org/repos/asf/hertzbeat.git
The following commit(s) were added to refs/heads/alarm-inhibit by this push:
new fd5091cc4 [improve] fix collector scheduler bug
fd5091cc4 is described below
commit fd5091cc4dd0ebfb3cf731b043b0cf7b911a925e
Author: tomsun28 <[email protected]>
AuthorDate: Wed Jan 8 10:11:23 2025 +0800
[improve] fix collector scheduler bug
Signed-off-by: tomsun28 <[email protected]>
---
.../apache/hertzbeat/manager/scheduler/CollectorJobScheduler.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/CollectorJobScheduler.java
b/hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/CollectorJobScheduler.java
index 30d02a28d..5fbd6fb41 100644
---
a/hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/CollectorJobScheduler.java
+++
b/hertzbeat-manager/src/main/java/org/apache/hertzbeat/manager/scheduler/CollectorJobScheduler.java
@@ -244,7 +244,7 @@ public class CollectorJobScheduler implements
CollectorScheduling, CollectJobSch
.setIdentity(identity)
.build();
ClusterMsg.Message response = this.manageServer.sendMsgSync(identity,
message);
- if (response == null ||
!String.valueOf(CommonConstants.SUCCESS_CODE).equals(response.getMsg())) {
+ if (response == null ||
!String.valueOf(CommonConstants.SUCCESS_CODE).equals(response.getMsg().toString()))
{
return false;
}
log.info("send offline collector message to {} success", identity);
@@ -264,7 +264,7 @@ public class CollectorJobScheduler implements
CollectorScheduling, CollectJobSch
.setIdentity(identity)
.build();
ClusterMsg.Message response = this.manageServer.sendMsgSync(identity,
message);
- if (response == null ||
!String.valueOf(CommonConstants.SUCCESS_CODE).equals(response.getMsg())) {
+ if (response == null ||
!String.valueOf(CommonConstants.SUCCESS_CODE).equals(response.getMsg().toString()))
{
return false;
}
log.info("send online collector message to {} success", identity);
@@ -442,7 +442,7 @@ public class CollectorJobScheduler implements
CollectorScheduling, CollectJobSch
.build();
this.manageServer.sendMsg(node.getIdentity(),
deleteMessage);
}
- break;
+ // break; if is there jod exist in multi collector?
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
