You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "Nicholas Jiang (Jira)" <ji...@apache.org> on 2023/07/16 16:58:00 UTC

[jira] [Created] (HUDI-6540) Support failed writes clean policy for Flink

Nicholas Jiang created HUDI-6540:
------------------------------------

             Summary: Support failed writes clean policy for Flink
                 Key: HUDI-6540
                 URL: https://issues.apache.org/jira/browse/HUDI-6540
             Project: Apache Hudi
          Issue Type: Improvement
          Components: flink
            Reporter: Nicholas Jiang
            Assignee: Nicholas Jiang
             Fix For: 0.14.0


The failed writes clean policy should be lazy when write concurrency mode is optimistic concurrency control. FlinkOptions should support to config failed writes clean policy. The parameters of FlinkStreamerConfig, FlinkCompactionConfig and FlinkClusteringConfig should also support failed writes clean policy parameter. Meanwhile, append mode without inline clustering should add clean operator in pipeline to rollback failed writes.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)