ES文档中有句话不太清楚，求英语好的或者用过的帮忙讲一下？

Question

import org.elasticsearch.action.bulk.BackoffPolicy;
import org.elasticsearch.action.bulk.BulkProcessor;
import org.elasticsearch.common.unit.ByteSizeUnit;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;

BulkProcessor bulkProcessor = BulkProcessor.builder(
        client,  
        new BulkProcessor.Listener() {
            @Override
            public void beforeBulk(long executionId,
                                   BulkRequest request) { ... } 

            @Override
            public void afterBulk(long executionId,
                                  BulkRequest request,
                                  BulkResponse response) { ... } 

            @Override
            public void afterBulk(long executionId,
                                  BulkRequest request,
                                  Throwable failure) { ... } 
        })
        .setBulkActions(10000) 
        .setBulkSize(new ByteSizeValue(5, ByteSizeUnit.MB)) 
        .setFlushInterval(TimeValue.timeValueSeconds(5)) 
        .setConcurrentRequests(1) 
        .setBackoffPolicy(
            BackoffPolicy.exponentialBackoff(TimeValue.timeValueMillis(100), 3)) 
        .build();

这段是BulkProcessor章节的一段代码，其中倒数第2/3行:

.setBackoffPolicy(
            BackoffPolicy.exponentialBackoff(TimeValue.timeValueMillis(100), 3)) 

文档中给的解释是:

Set a custom backoff policy which will initially wait for 100ms, increase exponentially and retries up to three times. A retry is attempted whenever one or more bulk item requests have failed with an EsRejectedExecutionException which indicates that there were too little compute resources available for processing the request. To disable backoff, pass BackoffPolicy.noBackoff().

然后我就不太理解了，这里面的 increase exponentially 是什么意思？

然后我注意到文档再往下一点有一个默认的例子是这样的:

sets backoffPolicy to an exponential backoff with 8 retries and a start delay of 50ms. The total wait time is roughly 5.1 seconds.

它说默认情况第一次延迟50ms，一共8次，最后算出来的却是5.1s左右。这个5.1s是怎么算出来的呢？

Answer 1

可是不对啊，我去官方提问了，他回复我就是翻倍，第一次50ms，第二次就是100ms，然后是200ms，but....这个5.1是咋来的。。。

Answer 2

还给个个源码中使用的公式 int result = start + 10 * ((int) Math.exp(0.8d * (currentlyConsumed)) - 1);

Answer 3

回复
@哎码 : Math.exp() 函数返回 e的x方，x 表示参数。所以不是简单的倍数关系

Answer 4

就是重试的初始时间间隔是100ms，如果重试失败的话这个间隔也会随之增长。

第一次重试失败   100ms

第二次重试失败    500ms

第三次重试失败    2s

。。。

超时这东西如果在一段时间内发生的话，你重试多少次都没有用，所以他为了不浪费性能，如果多次尝试都不成功那就延长重试的时间间隔。

 

increase exponentially  ： 呈指数增长