Skip to content

Commit b9bfb0a

Browse files
committed
format code
1 parent 611fd11 commit b9bfb0a

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,13 +128,15 @@ private void commitIfNecessary(String instant, Collection<CompactionCommitEvent>
128128
if (!isReady) {
129129
return;
130130
}
131+
131132
if(events.stream().anyMatch(CompactionCommitEvent::isFailed)) {
132133
// handle failure case
133134
CompactionUtil.rollbackCompaction(table, instant);
134135
// remove commitBuffer avoid commit with preview fileId
135136
this.commitBuffer.remove(instant);
136137
return;
137138
}
139+
138140
try {
139141
doCommit(instant, events);
140142
} catch (Throwable throwable) {

0 commit comments

Comments
 (0)