in lifecycle/src/main/java/org/apache/shardingsphere/elasticjob/lifecycle/internal/operate/JobOperateAPIImpl.java [125:141]
public void remove(final String jobName, final String serverIp) {
shutdown(jobName, serverIp);
if (null != jobName && null != serverIp) {
regCenter.remove(new JobNodePath(jobName).getServerNodePath(serverIp));
} else if (null != jobName) {
JobNodePath jobNodePath = new JobNodePath(jobName);
List<String> servers = regCenter.getChildrenKeys(jobNodePath.getServerNodePath());
for (String each : servers) {
regCenter.remove(jobNodePath.getServerNodePath(each));
}
} else if (null != serverIp) {
List<String> jobNames = regCenter.getChildrenKeys("/");
for (String each : jobNames) {
regCenter.remove(new JobNodePath(each).getServerNodePath(serverIp));
}
}
}