We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5a615e7 commit 57a78cbCopy full SHA for 57a78cb
test/clj/backtype/storm/nimbus_test.clj
@@ -440,6 +440,22 @@
440
))))
441
)))
442
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
459
(deftest test-cleans-corrupt
460
(with-inprocess-zookeeper zk-port
461
(with-local-tmp [nimbus-dir]
0 commit comments