(seatunnel) branch dev updated: The isNullable attribute is true when the primary key field in the Paimon table converts the Column object. #7231 (#7242)

[wanghailin]

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

wanghailin 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 b0fe432e99 The isNullable attribute is true when the primary key field 
in the Paimon table converts the Column object. #7231 (#7242)
b0fe432e99 is described below

commit b0fe432e9988693c7fa572782c815a04bbefdc05
Author: hawk9821 <39961809+hawk9...@users.noreply.github.com>
AuthorDate: Mon Jul 22 16:12:12 2024 +0800

    The isNullable attribute is true when the primary key field in the Paimon 
table converts the Column object. #7231 (#7242)
---
 .../seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java
 
b/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java
index 2c9fcd6f82..d896e01539 100644
--- 
a/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java
+++ 
b/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java
@@ -222,7 +222,8 @@ public class PaimonCatalog implements Catalog, PaimonTable {
                             BasicTypeDefine.<DataType>builder()
                                     .name(dataField.name())
                                     .comment(dataField.description())
-                                    .nativeType(dataField.type());
+                                    .nativeType(dataField.type())
+                                    .nullable(dataField.type().isNullable());
                     Column column = 
SchemaUtil.toSeaTunnelType(typeDefineBuilder.build());
                     builder.column(column);
                 });