Hi, Kai,
I think the exception should be thrown from
RetryRejectedExecutionFailureHandler as you configure the
'failure-handler' to 'retry-rejected'. It will retry the action that
failed with EsRejectedExecutionException and throw all other failures.
AFAIK, there is no way to configure the connec
With some investigation in the task manager's log, the exception was raised
from RetryRejectedExecutionFailureHandler path, the related logs are
showing below, not sure why it's that.
* 5978 2021-06-05 05:31:31,529 INFO
org.apache.flink.elasticsearch7.shade
