Indeed very difficult to simulate with an http 400 bad formatted doc. The batch will be retried until maxAttempts is reached because it will still contain a bad formatted doc. The only way would be to test with an error that can be temporary (like an ES status) and control the embeded ES through a separate thread in the UT to change that status. But now that you changed the logic in `handleRetry()` and considering that you test your predicate in a separate UT, I think it is fine.
[ Full content available at: https://github.com/apache/beam/pull/6146 ] This message was relayed via gitbox.apache.org for [email protected]
