Skip to content

Commit 7929a13

Browse files
author
Nathan Marz
committed
get rid of unassignbyexecutor method
1 parent 86a787d commit 7929a13

File tree

2 files changed

+0
-17
lines changed

2 files changed

+0
-17
lines changed

src/jvm/backtype/storm/scheduler/SchedulerAssignment.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -35,19 +35,6 @@ public void assign(WorkerSlot slot, Collection<ExecutorDetails> executors) {
3535
this.executorToSlot.put(executor, slot);
3636
}
3737
}
38-
39-
/**
40-
* Unassign the assignment for executor.
41-
*/
42-
public void unassignByExecutor(ExecutorDetails executor) {
43-
this.executorToSlot.remove(executor);
44-
}
45-
46-
public void unassignByExecutors(Collection<ExecutorDetails> executors) {
47-
for (ExecutorDetails executor : executors) {
48-
this.unassignByExecutor(executor);
49-
}
50-
}
5138

5239
/**
5340
* Release the slot occupied by this assignment.

test/clj/backtype/storm/scheduler_test.clj

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,10 +47,6 @@
4747
(is (= {[6 10] ["supervisor2" 2]}
4848
(clojurify-executor->slot (.getExecutorToSlot assignment))))
4949

50-
;; test unassignByExecutor
51-
(.unassignByExecutor assignment (ExecutorDetails. (int 6) (int 10)))
52-
(is (= true
53-
(empty? (.getExecutorToSlot assignment))))
5450
))
5551

5652
(deftest test-topologies

0 commit comments

Comments
 (0)