(shardingsphere-elasticjob) branch master updated: Fix remove offline server (#2445)

[linghengqian]

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 <che...@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));