From b0fe432e9988693c7fa572782c815a04bbefdc05 Mon Sep 17 00:00:00 2001
From: hawk9821 <39961809+hawk9821@users.noreply.github.com>
Date: Mon, 22 Jul 2024 16:12:12 +0800
Subject: [PATCH] The isNullable attribute is true when the primary key field
 in the Paimon table converts the Column object. #7231 (#7242)

---
 .../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 2c9fcd6f828..d896e015398 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 @@ private CatalogTable toCatalogTable(
                             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);
                 });