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)

Reply via email to