thbay opened a new pull request, #127: URL: https://github.com/apache/flink-connector-elasticsearch/pull/127
When using flink-connector-elasticsearch8 ver. 3.1.0-1.20 with flink ver. 1.20.1, the retry of failed index operations has two problems: 1. the isRetryable method is testing error.getCause() which is null in case of ConnectException and other exceptions 2. ELASTICSEARCH_FATAL_EXCEPTION_CLASSIFIER.isFatal() method returns true if exception is not thrown, resulting in the isRetryable() method returns the wrong result. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
