(inlong) branch master updated: [INLONG-9273][Sort] IcebergSingleFileCommiter will throw exception for error code (#9274)

[zirui]

This is an automated email from the ASF dual-hosted git repository.

zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 024690ce82 [INLONG-9273][Sort] IcebergSingleFileCommiter will throw 
exception for error code (#9274)
024690ce82 is described below

commit 024690ce825c92abaa81aba815e33f57b3c202b9
Author: Xin Gong <genzhedangd...@gmail.com>
AuthorDate: Tue Nov 14 19:58:15 2023 +0800

    [INLONG-9273][Sort] IcebergSingleFileCommiter will throw exception for 
error code (#9274)
---
 .../inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java   | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java
 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java
index 074feec342..1c7016fdc2 100644
--- 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java
+++ 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java
@@ -316,9 +316,6 @@ public class IcebergSingleFileCommiter extends 
IcebergProcessFunction<WriteResul
             }
             continuousEmptyCheckpoints = 0;
         }
-        // remove already committed snapshot manifest info
-
-        pendingMap.keySet().forEach(deltaManifestsMap::remove);
         pendingMap.clear();
 
         // Delete the committed manifests.