There is a `NoOpFailureHandler` used in ElasticsearchSink which throws the 
exception as well. I referred to that class while naming the failureHandler in 
CassandraSink.
Should I rename the class?

[ Full content available at: https://github.com/apache/flink/pull/6732 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to