FaxianZhao created FLINK-13036:
----------------------------------
Summary: Elasticsearch ActionRequestFailureHandler can access RuntimeContext
Key: FLINK-13036
URL:
https://issues.apache.org/jira/browse/FLINK-13036 Project: Flink
Issue Type: Improvement
Components: Connectors / ElasticSearch
Reporter: FaxianZhao
We can not count exceptions via accumulator in ActionRequestFailureHandler to check message count end-to-end consistency otherwize log them or use external counter.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)