[Improve][Connector-V2] Reduce the request times of iceberg load table (

#8149)
apache · Nov 27, 2024 · 555f5eb · 555f5eb
1 parent 399eabc
commit 555f5eb
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...apache/seatunnel/connectors/seatunnel/iceberg/sink/commit/IcebergAggregatedCommitter.java b/...apache/seatunnel/connectors/seatunnel/iceberg/sink/commit/IcebergAggregatedCommitter.java
@@ -36,7 +36,7 @@ public class IcebergAggregatedCommitter
     private final IcebergFilesCommitter filesCommitter;
 
     public IcebergAggregatedCommitter(SinkConfig config, CatalogTable catalogTable) {
-        IcebergTableLoader tableLoader = IcebergTableLoader.create(config, catalogTable).open();
+        IcebergTableLoader tableLoader = IcebergTableLoader.create(config, catalogTable);
         this.filesCommitter = IcebergFilesCommitter.of(config, tableLoader);
     }
 
@@ -51,7 +51,8 @@ public List<IcebergAggregatedCommitInfo> commit(
 
     private void commitFiles(List<IcebergCommitInfo> commitInfos) {
         for (IcebergCommitInfo icebergCommitInfo : commitInfos) {
-            if (icebergCommitInfo.getResults() == null) {
+            if (icebergCommitInfo.getResults() == null
+                    || icebergCommitInfo.getResults().isEmpty()) {
                 continue;
             }
             filesCommitter.doCommit(icebergCommitInfo.getResults());