flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8401) Allow subclass to override write-failure behavior in CassandraOutputFormat
Date Mon, 15 Jan 2018 11:13:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-8401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16326136#comment-16326136
] 

ASF GitHub Bot commented on FLINK-8401:
---------------------------------------

Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5274#discussion_r161489395
  
    --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java
---
    @@ -66,6 +66,13 @@ public void configure(Configuration parameters) {
     		this.cluster = builder.getCluster();
     	}
     
    +	protected void onWriteSuccess(ResultSet ignored) {
    --- End diff --
    
    JavaDocs missing


> Allow subclass to override write-failure behavior in CassandraOutputFormat 
> ---------------------------------------------------------------------------
>
>                 Key: FLINK-8401
>                 URL: https://issues.apache.org/jira/browse/FLINK-8401
>             Project: Flink
>          Issue Type: Improvement
>          Components: Cassandra Connector
>            Reporter: Shuyi Chen
>            Assignee: Shuyi Chen
>            Priority: Major
>
> 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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message