Skip to content

Commit

Permalink
kill some whitespace
Browse files Browse the repository at this point in the history
  • Loading branch information
Hendrik Muhs committed Mar 9, 2021
1 parent 4291370 commit 9aedea4
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,6 @@ private TransformNodes() {}
* @return The {@link TransformNodeAssignments} for the given transforms.
*/
public static TransformNodeAssignments transformTaskNodes(List<String> transformIds, ClusterState clusterState) {

Set<String> executorNodes = new HashSet<>();
Set<String> assigned = new HashSet<>();
Set<String> waitingForAssignment = new HashSet<>();
Expand Down Expand Up @@ -82,7 +81,6 @@ public static TransformNodeAssignments transformTaskNodes(List<String> transform
* @return The {@link TransformNodeAssignments} for the given transforms.
*/
public static TransformNodeAssignments findActiveTasks(String transformId, ClusterState clusterState) {

Set<String> executorNodes = new HashSet<>();
Set<String> assigned = new HashSet<>();
Set<String> waitingForAssignment = new HashSet<>();
Expand All @@ -104,7 +102,6 @@ public static TransformNodeAssignments findActiveTasks(String transformId, Clust
}
}
}

return new TransformNodeAssignments(executorNodes, assigned, waitingForAssignment, Collections.emptySet());
}

Expand All @@ -118,15 +115,13 @@ public static TransformNodeAssignments findActiveTasks(String transformId, Clust
*/
public static Assignment getAssignment(String transformId, ClusterState clusterState) {
PersistentTasksCustomMetadata tasksMetadata = PersistentTasksCustomMetadata.getPersistentTasksCustomMetadata(clusterState);

PersistentTask<?> task = tasksMetadata.getTask(transformId);

if (task != null) {
return task.getAssignment();
}

return PersistentTasksCustomMetadata.INITIAL_ASSIGNMENT;

}

/**
Expand Down

0 comments on commit 9aedea4

Please sign in to comment.