fixed

sunxiaojian · Jan 15, 2024 · 52cb4fb · 52cb4fb
1 parent 159d01c
commit 52cb4fb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergRecordWriter.java b/...va/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergRecordWriter.java
@@ -109,8 +109,8 @@ public List<WriteResult> complete() {
 
     /** Reset record writer */
     private void resetWriter() {
-        this.writer = null;
         this.writer = createTaskWriter();
+        this.recordConverter = new SeaTunnelRowConverter(table, config);
     }
 
     private void flush() {