https://git.corp.yahoo.com/storm/storm/blob/master-security/storm-core/src/clj/backtype/storm/testing.clj#L167
Try changing this. The time-out was added to prevent the case when a test
would hang indefinitely. Five seconds was thought to be more than enough time
to let tests pass. If it needs to be longer we could increase it.
If you continue to see the time-out, it could be that the test really is
hanging somehow.
--
Derek
On 5/19/14, 4:57, Sergey Pichkurov wrote:
Hello, Storm community.
I trying to write unit test with
storm.version :0.9.1-incubating
storm-kafka-0.8-plus: 0.4.0
My topology have one Kafka spout and one storing bolt which has Spring
inside(context initialized in prepare() method).
When I running test with Testing.completeTopology(), I am getting error:
java.lang.AssertionError: Test timed out (5000ms)
at
backtype.storm.testing$complete_topology.doInvoke(testing.clj:475)
at clojure.lang.RestFn.invoke(RestFn.java:826)
at
backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:61)
at backtype.storm.Testing.completeTopology(Unknown Source)
This error not always arise, sometime test pass successfully.
Where I can change this timeout parameter? Or how can I disable this timeout?
