From d10a3b221bbc82eddb551189aaeab71d2a8cc673 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=BB=9F=E5=BC=8B?= <yejunhao.yjh@alibaba-inc.com>
Date: Tue, 10 Dec 2024 15:00:33 +0800
Subject: [PATCH] fix comment

---
 .../java/org/apache/paimon/io/KeyValueFileWriterFactory.java  | 4 +---
 1 file changed, 1 insertion(+), 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
index 2e25c4b1e539..87f53ab5b013 100644
--- 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);