fix comment

apache · Dec 10, 2024 · fe09553 · fe09553
1 parent 52b1601
commit fe09553
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriter.java
@@ -84,6 +84,7 @@ public KeyValueDataFileWriter(
             Function<KeyValue, InternalRow> converter,
             RowType keyType,
             RowType valueType,
+            RowType writeRowType,
             @Nullable SimpleStatsExtractor simpleStatsExtractor,
             long schemaId,
             int level,
@@ -96,14 +97,11 @@ public KeyValueDataFileWriter(
                 factory,
                 path,
                 converter,
-                KeyValue.schema(options.thinMode() ? RowType.of() : keyType, valueType),
+                writeRowType,
                 simpleStatsExtractor,
                 compression,
                 StatsCollectorFactories.createStatsFactories(
-                        options,
-                        KeyValue.schema(options.thinMode() ? RowType.of() : keyType, valueType)
-                                .getFieldNames(),
-                        keyType.getFieldNames()),
+                        options, writeRowType.getFieldNames(), keyType.getFieldNames()),
                 options.asyncFileWrite());
 
         this.keyType = keyType;

diff --git a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriterImpl.java b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueDataFileWriterImpl.java
@@ -60,6 +60,7 @@ public KeyValueDataFileWriterImpl(
                 converter,
                 keyType,
                 valueType,
+                KeyValue.schema(keyType, valueType),
                 simpleStatsExtractor,
                 schemaId,
                 level,

diff --git a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueThinDataFileWriterImpl.java b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueThinDataFileWriterImpl.java
@@ -84,6 +84,7 @@ public KeyValueThinDataFileWriterImpl(
                 converter,
                 keyType,
                 valueType,
+                KeyValue.schema(RowType.of(), valueType),
                 simpleStatsExtractor,
                 schemaId,
                 level,