Browse Source

[DS-6616][WorkerServer] fix worker stop fail and fakes death (#6621)

* [DS-6616][WorkerServer] fix worker stop fail and fakes death

* remove unuse test

* just add try catch to remove zk worker path

Co-authored-by: caishunfeng <534328519@qq.com>
2.0.7-release
wind 3 years ago committed by lenboo
parent
commit
d83661db25
  1. 17
      dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistryClient.java

17
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/registry/WorkerRegistryClient.java

@ -122,15 +122,22 @@ public class WorkerRegistryClient {
* remove registry info * remove registry info
*/ */
public void unRegistry() { public void unRegistry() {
String address = getLocalAddress(); try {
Set<String> workerZkPaths = getWorkerZkPaths(); String address = getLocalAddress();
for (String workerZkPath : workerZkPaths) { Set<String> workerZkPaths = getWorkerZkPaths();
registryClient.remove(workerZkPath); for (String workerZkPath : workerZkPaths) {
logger.info("worker node : {} unRegistry from ZK {}.", address, workerZkPath); registryClient.remove(workerZkPath);
logger.info("worker node : {} unRegistry from ZK {}.", address, workerZkPath);
}
} catch (Exception ex) {
logger.error("remove worker zk path exception", ex);
} }
this.heartBeatExecutor.shutdownNow(); this.heartBeatExecutor.shutdownNow();
logger.info("heartbeat executor shutdown"); logger.info("heartbeat executor shutdown");
registryClient.close(); registryClient.close();
logger.info("registry client closed");
} }
/** /**

Loading…
Cancel
Save