Skip to content

Commit 0f16275

Browse files
committed
fix: Fix paimon IllegalThreadStateException
(cherry picked from commit d7766fe)
1 parent 0054019 commit 0f16275

File tree

1 file changed

+4
-4
lines changed
  • connectors/paimon-connector/src/main/java/io/tapdata/connector/paimon/service

1 file changed

+4
-4
lines changed

connectors/paimon-connector/src/main/java/io/tapdata/connector/paimon/service/PaimonService.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -796,11 +796,11 @@ private WriteListResult<TapRecordEvent> writeRecordsWithStreamWriteInternal(List
796796
WriteListResult<TapRecordEvent> result = new WriteListResult<>();
797797
Identifier identifier = Identifier.create(database, tableName);
798798

799-
// Get or create cached writer and commit
800-
StreamTableWrite writer = getOrCreateStreamWriter(tableKey, identifier);
801-
StreamTableCommit commit = getOrCreateStreamCommit(tableKey, identifier);
802-
803799
try {
800+
// Get or create cached writer and commit
801+
StreamTableWrite writer = getOrCreateStreamWriter(tableKey, identifier);
802+
StreamTableCommit commit = getOrCreateStreamCommit(tableKey, identifier);
803+
804804
// Write all records to the writer
805805
for (TapRecordEvent event : recordEvents) {
806806
if (event instanceof TapInsertRecordEvent) {

0 commit comments

Comments
 (0)