(paimon) branch master updated: [core] make rowType not nullable for KeyValue and AppendOnlyFileStore (#5394)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 287a487f05 [core] make rowType not nullable for KeyValue and 
AppendOnlyFileStore (#5394)
287a487f05 is described below

commit 287a487f051eb220a3290387dc75800bf47e13c8
Author: LsomeYeah <94825748+lsomey...@users.noreply.github.com>
AuthorDate: Thu Apr 3 13:35:18 2025 +0800

    [core] make rowType not nullable for KeyValue and AppendOnlyFileStore 
(#5394)
---
 paimon-core/src/main/java/org/apache/paimon/KeyValue.java               | 2 +-
 .../src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/paimon-core/src/main/java/org/apache/paimon/KeyValue.java 
b/paimon-core/src/main/java/org/apache/paimon/KeyValue.java
index 36ac88996c..c314f21107 100644
--- a/paimon-core/src/main/java/org/apache/paimon/KeyValue.java
+++ b/paimon-core/src/main/java/org/apache/paimon/KeyValue.java
@@ -111,7 +111,7 @@ public class KeyValue {
     }
 
     public static RowType schema(RowType keyType, RowType valueType) {
-        return new RowType(createKeyValueFields(keyType.getFields(), 
valueType.getFields()));
+        return new RowType(false, createKeyValueFields(keyType.getFields(), 
valueType.getFields()));
     }
 
     public static RowType schemaWithLevel(RowType keyType, RowType valueType) {
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
 
b/paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
index 3448a4ddd4..26e5dd5a2b 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/table/AppendOnlyFileStoreTable.java
@@ -76,7 +76,7 @@ public class AppendOnlyFileStoreTable extends 
AbstractFileStoreTable {
                             new CoreOptions(tableSchema.options()),
                             tableSchema.logicalPartitionType(),
                             tableSchema.logicalBucketKeyType(),
-                            tableSchema.logicalRowType(),
+                            tableSchema.logicalRowType().notNull(),
                             name(),
                             catalogEnvironment);
         }