Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[SUPPORT] Apply 'write.ignore.failed' when write data failed #12187

Open
fhan688 opened this issue Oct 31, 2024 · 1 comment
Open

[SUPPORT] Apply 'write.ignore.failed' when write data failed #12187

fhan688 opened this issue Oct 31, 2024 · 1 comment

Comments

@fhan688
Copy link
Contributor

fhan688 commented Oct 31, 2024

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

  1. promote 'write.ignore.failed' to hudi-client-common
  2. throw exception in write handles
  3. default value of 'write.ignore.failed' is false

Environment Description

Additional context

related PR:#12150

Stacktrace

@danny0405
Copy link
Contributor

@nbalajee Do you have some insights about promote the 'write.ignore.failed' as a basic option for all the engines? I kind of remember we had a discussion before and engine specific maintainance is prefferable.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants