Skip to content

Commit 57a78cb

Browse files
author
Nathan Marz
committed
added test for submitting topology with invalid number of executors
1 parent 5a615e7 commit 57a78cb

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

test/clj/backtype/storm/nimbus_test.clj

+16
Original file line numberDiff line numberDiff line change
@@ -440,6 +440,22 @@
440440
))))
441441
)))
442442

443+
(deftest test-submit-invalid
444+
(with-simulated-time-local-cluster [cluster
445+
:daemon-conf {SUPERVISOR-ENABLE false
446+
TOPOLOGY-ACKER-EXECUTORS 0}]
447+
(letlocals
448+
(bind topology (thrift/mk-topology
449+
{"1" (thrift/mk-spout-spec (TestPlannerSpout. true) :parallelism-hint 0 :conf {TOPOLOGY-TASKS 1})}
450+
{}))
451+
452+
(is (thrown? InvalidTopologyException
453+
(submit-local-topology (:nimbus cluster)
454+
"test"
455+
{}
456+
topology)))
457+
)))
458+
443459
(deftest test-cleans-corrupt
444460
(with-inprocess-zookeeper zk-port
445461
(with-local-tmp [nimbus-dir]

0 commit comments

Comments
 (0)