Hystrix: why rollingStats.timeInMilliseconds is not taking effect?

Question

This is an experimental setup I have done: rollingStats.timeInMilliseconds: 100 sleepWindowInMilliseconds: 200000 errorThresholdPercentage: 20 requestVolumeThreshold: 1

My intention was to create a scenario, where right after 1 failure it will go sleep window , so it will not execute run unless 200 seconds are over. But what I see is, it tries more than 3 seconds after the 1st failure, that means it kept calling run method. I must be wrong somehwere. Please give me some direction.

package com.test.mock;


import com.netflix.config.ConfigurationManager;
import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixCommandProperties.ExecutionIsolationStrategy;
import com.netflix.hystrix.strategy.concurrency.HystrixRequestContext;
import com.sun.jersey.api.client.Client;
import com.sun.jersey.api.client.WebResource;

public class HystrixDemoCommand extends HystrixCommand<String> {

    public HystrixDemoCommand() throws Exception {
        
        super(HystrixCommandGroupKey.Factory.asKey("HystrixDemoCommandGroup"));
        HystrixCommandGroupKey.Factory.asKey("HystrixDemoCommandGroup");
        
        try {

            ConfigurationManager.getConfigInstance().setProperty("hystrix.command.HystrixDemoCommandGroup.execution.isolation.strategy", ExecutionIsolationStrategy.SEMAPHORE);
            ConfigurationManager.getConfigInstance().setProperty("hystrix.command.HystrixDemoCommandGroup.metrics.rollingStats.timeInMilliseconds", 100);

            ConfigurationManager.getConfigInstance().setProperty("hystrix.command.HystrixDemoCommandGroup.circuitBreaker.sleepWindowInMilliseconds", 200000);

            ConfigurationManager.getConfigInstance().setProperty("hystrix.command.HystrixDemoCommandGroup.circuitBreaker.errorThresholdPercentage", 20);

            ConfigurationManager.getConfigInstance().setProperty("hystrix.command.HystrixDemoCommandGroup.circuitBreaker.requestVolumeThreshold", 1);


            
        } catch (Exception exception) {
           throw new Exception("error initializing hystrix");

        }


    }

    @Override
    protected String run() throws Exception {
        /**client code starts here**/
        System.out.println("planning to execute run");
        Client client = Client.create();
        WebResource webresource = client.resource("https://a73c392-510a-4df3-9898-6e18dd2f773c.mock.pstmn.io/mockName");
        String responseStr = webresource.get(String.class);
        System.out.println("printing response:" + responseStr);
        return responseStr;
        /**client code ends here**/
    }

    protected String getFallback(){

        System.out.println("inside fallback");
        return "FALLBACK_0001";
        
    }
}

Answer 1

等待大神解答