andyzhangdialpad
andyzhangdialpad
Thank you all for commenting! Really appreciate it. @Aneurysm9 My understanding of otel collector internal is still limited so I will leave others to discuss the re-aggregation. However, I saw...
Added test code. Currently test write two docs, the valid one is going to `SUCCESSFUL_WRITES` and the one with long id is going to `FAILED_WRITES`. @egalpin I was trying to...
@egalpin addressed comments. Could you take a look again? Thank you!
Looks like test is failing: https://github.com/apache/beam/pull/31151/checks?check_run_id=24958553387 because `org.elasticsearch.client.ResponseException` also throws [HTTP/1.1 503 Service Unavailable]. Looks like beam expects this is going to throw exception so that it can retry es...
On a second thought, we can probably - throw exception for http code is 5xx except 501, I found this approach at https://github.com/hashicorp/go-retryablehttp - route to FAILED_WRITE for the rest
Will add 5xx except 501 handling in isRetryableClientException()