lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3703] Reset taskID in restoreWriteMetadata (#5122)

Browse Source
This commit is contained in:
Zhaojing Yu
2022-03-25 10:18:28 +08:00
committed by GitHub
parent eaa4c4f2e2
commit 483ee843e6
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java
View File

@@ -182,6 +182,8 @@ public abstract class AbstractStreamWriteFunction<I>
boolean eventSent = false; boolean eventSent = false;
for (WriteMetadataEvent event : this.writeMetadataState.get()) { for (WriteMetadataEvent event : this.writeMetadataState.get()) {
if (Objects.equals(lastInflight, event.getInstantTime())) { if (Objects.equals(lastInflight, event.getInstantTime())) {
// Reset taskID for event
event.setTaskID(taskID);
// The checkpoint succeed but the meta does not commit, // The checkpoint succeed but the meta does not commit,
// re-commit the inflight instant // re-commit the inflight instant
this.eventGateway.sendEventToCoordinator(event); this.eventGateway.sendEventToCoordinator(event);