fix comment

apache · Dec 10, 2024 · d10a3b2 · d10a3b2
1 parent 1adbe5c
commit d10a3b2
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java b/paimon-core/src/main/java/org/apache/paimon/io/KeyValueFileWriterFactory.java
@@ -196,14 +196,12 @@ private Builder(
 
         public KeyValueFileWriterFactory build(
                 BinaryRow partition, int bucket, CoreOptions options) {
-            RowType finalKeyType = options.thinMode() ? RowType.of() : keyType;
-            RowType writeKeyType = KeyValue.schema(finalKeyType, valueType);
             WriteFormatContext context =
                     new WriteFormatContext(
                             partition,
                             bucket,
                             keyType,
-                            writeKeyType,
+                            KeyValue.schema(options.thinMode() ? RowType.of() : keyType, valueType),
                             fileFormat,
                             format2PathFactory,
                             options);