I can see that the test time out is set to 5000ms in https://github.com/apache/incubator-storm/blob/master/storm-core/src/clj/backtype/storm/testing.clj. Is there anyway to override this value?
On Mon, Sep 8, 2014 at 1:39 PM, Devika Nair <[email protected]> wrote: > Hi all, > > > I am trying to follow the example on > https://github.com/xumingming/storm-lib/blob/master/src/jvm/storm/TestingApiDemo.java > and writing tests for my topology. > > > However, my tests(similar to testBasicTopology()) fail due to timeout > when I add a bolt(the prepare for this bolt takes quite long). Is there any > way to increase the timeout? I have been looking around, but unable to find > any. If I send my spout data to TestWordCounter it works. > > > > THIS WORKS > public void run(ILocalCluster cluster) { // build the test topology > TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("1", > new MySpout(true), 1); builder.setBolt("2", new TestWordCounter(), 1 > ).shuffleGrouping("1"); > > THIS DOES NOT WORK > public void run(ILocalCluster cluster) { // build the test topology > TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("1", new > MySpout(true), 1); builder.setBolt("2", new MyBolt(), 1).shuffleGrouping > ("1"); > > > Exception: > > java.lang.AssertionError: Test timed out (5000ms) > > at > backtype.storm.testing$complete_topology.doInvoke(testing.clj:454) > ~[storm-core-0.9.0.1.jar:na] > > at clojure.lang.RestFn.invoke(*RestFn.java:826*) > ~[clojure-1.4.0.jar:na] > > at > backtype.storm.testing4j$_completeTopology.invoke(testing4j.clj:45) > ~[storm-core-0.9.0.1.jar:na] > > at backtype.storm.Testing.completeTopology(Unknown Source) > [storm-core-0.9.0.1.jar:na] > > at analytics.AAMTopologyTest$1.run(*AAMTopologyTest.java:162*) > ~[test-classes/:na] > > at > backtype.storm.testing4j$_withSimulatedTimeLocalCluster$fn__7112.invoke(testing4j.clj:75) > [storm-core-0.9.0.1.jar:na] > > at > backtype.storm.testing4j$_withSimulatedTimeLocalCluster.invoke(testing4j.clj:75) > [storm-core-0.9.0.1.jar:na] > > at backtype.storm.Testing.withSimulatedTimeLocalCluster(Unknown > Source) [storm-core-0.9.0.1.jar:na] > > at analytics.AAMTopologyTest.testBasicTopology( > *AAMTopologyTest.java:90*) [test-classes/:na] > > at sun.reflect.NativeMethodAccessorImpl.invoke0(*Native Method*) > ~[na:1.7.0_65] > > at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) > ~[na:1.7.0_65] > > at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) > ~[na:1.7.0_65] > > at java.lang.reflect.Method.invoke(Unknown Source) ~[na:1.7.0_65] > > at junit.framework.TestCase.runTest(*TestCase.java:168*) > [junit-4.8.2.jar:na] > > at junit.framework.TestCase.runBare(*TestCase.java:134*) > [junit-4.8.2.jar:na] > > at junit.framework.TestResult$1.protect(*TestResult.java:110*) > [junit-4.8.2.jar:na] > > > Thanks, > > Devika > > >
