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)