The isNullable attribute is true when the primary key field in the Pa…

…imon table converts the Column object. apache#7231 (apache#7242)
jovezhong · Jul 22, 2024 · b0fe432 · b0fe432
1 parent 4b3af9b
commit b0fe432
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java b/...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);
                 });