Sorry- the ipv4 fix worked.

On Tue, Aug 5, 2014 at 9:13 PM, Corey Nolet <cjno...@gmail.com> wrote:

> This did work. Thanks!
>
>
> On Tue, Aug 5, 2014 at 2:23 PM, P. Taylor Goetz <ptgo...@gmail.com> wrote:
>
>> My guess is that the slowdown you are seeing is a result of the new
>> version of ZooKeeper and how it handles IPv4/6.
>>
>> Try adding the following JVM parameter when running your tests:
>>
>> -Djava.net.preferIPv4Stack=true
>>
>> -Taylor
>>
>> On Aug 4, 2014, at 8:49 PM, Corey Nolet <cjno...@gmail.com> wrote:
>>
>> > I'm testing some sliding window algorithms with tuples emitted from a
>> mock spout based on a timer but the amount of time it takes the topology to
>> fully start up and activate seems to vary from computer to computer.
>> Specifically, I just updated from 0.8.2 to 0.9.2-incubating and all of my
>> tests are breaking because the time to activate the topology is taking
>> longer (because of Netty possibly?). I'd like to make my tests more
>> resilient to things like this.
>> >
>> > Is there something I can look at in LocalCluster where I could do
>> "while(!notActive) { Thread.sleep(50) }" ?
>> >
>> > This is what my test looks like currently:
>> >
>> >       StormTopology topology = buildTopology(...);
>> >       Config conf = new Config();
>> >       conf.setNumWorkers(1);
>> >
>> >       LocalCluster cluster = new LocalCluster();
>> >       cluster.submitTopology(getTopologyName(), conf, topology);
>> >
>> >       try {
>> >         Thread.sleep(4000);
>> >       } catch (InterruptedException e) {
>> >         e.printStackTrace();
>> >       }
>> >
>> >       cluster.shutdown();
>> >
>> >       assertEquals(4, MockSinkBolt.getEvents().size());
>> >
>> >
>> >
>> > Thanks!
>> >
>> >
>>
>>
>

Reply via email to