You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by li...@apache.org on 2024/10/10 06:54:45 UTC
(shardingsphere-elasticjob) branch master updated: Fix remove offline server (#2445)
This is an automated email from the ASF dual-hosted git repository.
linghengqian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git
The following commit(s) were added to refs/heads/master by this push:
new b03ad56b1 Fix remove offline server (#2445)
b03ad56b1 is described below
commit b03ad56b122a86c53c46dd19f1debebd73dec039
Author: ooooooook <ch...@qq.com>
AuthorDate: Thu Oct 10 14:54:39 2024 +0800
Fix remove offline server (#2445)
Co-authored-by: cheyx <ch...@tsintergy.com>
---
.../elasticjob/kernel/internal/server/ServerService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/server/ServerService.java b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/server/ServerService.java
index 3810bb510..1d02955d5 100644
--- a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/server/ServerService.java
+++ b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/server/ServerService.java
@@ -109,7 +109,7 @@ public final class ServerService {
/**
* Remove unused server IP.
- *
+ *
* @return num of server IP to be removed
*/
public int removeOfflineServers() {
@@ -132,7 +132,7 @@ public final class ServerService {
return;
}
String status = jobNodeStorage.getJobNodeData(serverNode.getServerNode(serverIp));
- if (StringUtils.isNotBlank(status)) {
+ if (StringUtils.isBlank(status)) {
return;
}
jobNodeStorage.removeJobNodeIfExisted(serverNode.getServerNode(serverIp));