We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
@fpj , I think there is a bug, and it should be the workerName, not the path in getAbsentWorkerTasks(path)
ChildrenCallback workerAssignmentCallback = new ChildrenCallback() { public void processResult(int rc, String path, Object ctx, List<String> children){ switch (Code.get(rc)) { case CONNECTIONLOSS: getAbsentWorkerTasks(path); // Here should be path.subString(path.lastIndexOf('/') + 1, path.length()); break; case OK: LOG.info("Succesfully got a list of assignments: " + children.size() + " tasks"); /* * Reassign the tasks of the absent worker. */ for(String task: children) { getDataReassign(path + "/" + task, task); } break; default: LOG.error("getChildren failed", KeeperException.create(Code.get(rc), path)); } } };
zookeeper-book-example/src/main/java/org/apache/zookeeper/book/Master.java
Line 491 in 135b79b
The text was updated successfully, but these errors were encountered:
No branches or pull requests
@fpj , I think there is a bug, and it should be the workerName, not the path in getAbsentWorkerTasks(path)
zookeeper-book-example/src/main/java/org/apache/zookeeper/book/Master.java
Line 491 in 135b79b
The text was updated successfully, but these errors were encountered: