[FLINK-8401] Allow subclass to override write-failure behavior in CassandraOutputFormat

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.5.0
• Component/s: Connectors / Cassandra
• Assignee: Shuyi Chen
• Reporter: Shuyi Chen
• Created: 10/Jan/18 08:51
• Updated: 15/Feb/18 13:46
• Resolved: 15/Feb/18 13:46

Description

Currently it will throw an exception and fail the entire job, we would like to keep the current default behavior, but refactor the code to allow subclass to override and customize the failure handling.

Issue Links

• links to: GitHub Pull Request #5274