This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 857aab5e83 [Improve][Iceberg] Filter catalog table primaryKey is empty
(#8413)
857aab5e83 is described below
commit 857aab5e8361ef12a02fddd25fe0e85d3e56f153
Author: hailin0 <[email protected]>
AuthorDate: Thu Jan 2 14:06:02 2025 +0800
[Improve][Iceberg] Filter catalog table primaryKey is empty (#8413)
---
.../seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java
index ee87eba7aa..de21769cb8 100644
---
a/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java
+++
b/seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java
@@ -285,6 +285,7 @@ public class IcebergCatalog implements Catalog {
builder.column(physicalColumn);
});
Optional.ofNullable(schema.identifierFieldNames())
+ .filter(names -> !names.isEmpty())
.map(
(Function<Set<String>, Object>)
names ->
