Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/1962
Hi @sbcd90,
I think to address "add reconnect attempt" alone, checking whether or not
the transport client is connected to nodes and retry connect if lost connection
in `invoke()` before processing the element should be fine.
On the other hand, another problem that raises if we are to add reconnect
attempt for the ES sink is that failing records due to connection errors also
need to be caught in the `BulkProcessor` `afterBulk()` callback and
re-processed. I wonder if we should be solving this together to resolve this
issue. @rmetzger, what's your opinion?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
