Open
Description
Describe the problem you faced
In Flink engine, if exception occurs when task writing data, it will be ignored and the exception will be reported to StreamWriteCoordinator with write event, StreamWriteCoordinator will decide whether to commit when there is write failure according to 'write.ignore.failed'.
Whether we should apply 'write.ignore.failed' ahead when write failure occurs, thus throw an exception faster.
To Reproduce
Expected behavior
- promote 'write.ignore.failed' to hudi-client-common
- throw exception in write handles
- default value of 'write.ignore.failed' is false
Environment Description
Additional context
related PR:#12150
Stacktrace
Metadata
Assignees
Type
Projects
Status
⏳ Awaiting Triage