[
https://issues.apache.org/jira/browse/HUDI-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen closed HUDI-7132.
----------------------------
Fix Version/s: 0.14.1
Resolution: Fixed
Fixed via master branch: 17b62a2c0f47f86b436330f2b0ea109b8c8f743c
> Data may be lost in Flink checkpoint
> ------------------------------------
>
> Key: HUDI-7132
> URL: https://issues.apache.org/jira/browse/HUDI-7132
> Project: Apache Hudi
> Issue Type: Bug
> Components: flink
> Affects Versions: 0.13.1, 0.14.0
> Reporter: Bo Cui
> Priority: Major
> Labels: pull-request-available
> Fix For: 0.14.1
>
>
> https://github.com/apache/hudi/blob/a1afcdd989ce2d634290d1bd9e099a17057e6b4d/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java#L524C23-L524C35
> before the line code, eventBuffer may be updated by `subtaskFailed`, and some
> elements of eventBuffer is null
> https://github.com/apache/hudi/blob/a1afcdd989ce2d634290d1bd9e099a17057e6b4d/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java#L305C10-L305C21
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
