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)
