-
Type:
Improvement
-
Status: Resolved
-
Priority:
P2
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 2.7.0
-
Component/s: io-java-elasticsearch
-
Labels:None
Currently an overloaded ES server will result in clients failing fast.
I suggest implementing backoff pauses. Perhaps something like this:
ElasticsearchIO.ConnectionConfiguration conn = ElasticsearchIO.ConnectionConfiguration .create(new String[]{"http://...:9200"}, "test", "test") .retryWithWaitStrategy(WaitStrategies.exponentialBackoff(1000, TimeUnit.MILLISECONDS) .retryWithStopStrategy(StopStrategies.stopAfterAttempt(10) );
- links to