Tudor Plugaru created FLINK-32028: ------------------------------------- Summary: Error handling for ElasticSearch sink Key: FLINK-32028 URL: https://issues.apache.org/jira/browse/FLINK-32028 Project: Flink Issue Type: Improvement Components: Connectors / ElasticSearch Affects Versions: 1.16.1 Reporter: Tudor Plugaru
The deprecated ElasticsearchSink supports setting an error handler via a [public method |[https://github.com/apache/flink-connector-elasticsearch/blob/8f75d4e059c09b55cc3a44bab3e64330b1246d27/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java#L216],] but the new sink, does not. Ideally there would be a way to handle ES specific exceptions and be able to skip items from being retried on ES indefinitely and not block entirely the pipeline. -- This message was sent by Atlassian Jira (v8.20.10#820010)