The listed method no longer exists and was subsumed by
ExceptionUtils#findThrowable, which also gives access to the Throwable
if it could be found.
I have filed FLINK-14334 for updating the documentation.
On 02/10/2019 15:48, Nicholas Walton wrote:
Hi,
I’m trying to implement a failure
Hi,
I’m trying to implement a failure handler for ElasticSearch from the example in
the Flink documentation
DataStream input = ...;
input.addSink(new ElasticsearchSink<>(
config, transportAddresses,
new ElasticsearchSinkFunction() {...},
new ActionRequestFailureHandler() {
