[
https://issues.apache.org/jira/browse/HUDI-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791869#comment-17791869
]
Danny Chen commented on HUDI-7132:
----------------------------------
No, the faiure of one task will never triggers the successful checkpointing,
and another important fact is the coordinator executor is single working
thread, so it works like a message queue, the ckp success event should handle
before any failure messages.
> Data may be lost in flink#chk
> -----------------------------
>
> Key: HUDI-7132
> URL: https://issues.apache.org/jira/browse/HUDI-7132
> Project: Apache Hudi
> Issue Type: Bug
> Components: flink
> Affects Versions: 1.1.0
> Reporter: Bo Cui
> Priority: Major
>
> 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)
