Beam has already a [Backoff 
facility](https://github.com/apache/beam/blob/20aff13d36b4ac7d9b9a29fd9f6fb3e80a84214a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/FluentBackoff.java#L30)
 so probably worth using that one to avoid the extra dependency. Please take a 
look at the use of [Backoff in 
SolrIO](https://github.com/apache/beam/blob/20aff13d36b4ac7d9b9a29fd9f6fb3e80a84214a/sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java#L607)
 to see how it works, it seems like an easy rewrite. Notice that the default 
case is no retry so probably worth doing the same here, and that the user can 
parametrize the retry via a function like done [there 
too](https://github.com/apache/beam/blob/20aff13d36b4ac7d9b9a29fd9f6fb3e80a84214a/sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java#L261)

[ Full content available at: https://github.com/apache/beam/pull/6202 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to