Skip to content

Commit 5ddf8d4

Browse files
authored
[Hotfix][Connector-V2] Release resources even the task is crashed for paimon sink (#7726)
1 parent 0261f86 commit 5ddf8d4

File tree

1 file changed

+10
-6
lines changed
  • seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink

1 file changed

+10
-6
lines changed

seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -205,13 +205,17 @@ public void abortPrepare() {}
205205

206206
@Override
207207
public void close() throws IOException {
208-
if (Objects.nonNull(tableWrite)) {
209-
try {
210-
tableWrite.close();
211-
} catch (Exception e) {
212-
log.error("Failed to close table writer in paimon sink writer.", e);
213-
throw new SeaTunnelException(e);
208+
try {
209+
if (Objects.nonNull(tableWrite)) {
210+
try {
211+
tableWrite.close();
212+
} catch (Exception e) {
213+
log.error("Failed to close table writer in paimon sink writer.", e);
214+
throw new SeaTunnelException(e);
215+
}
214216
}
217+
} finally {
218+
committables.clear();
215219
}
216220
}
217221
}

0 commit comments

Comments
 (0)