diff --git a/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java b/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java
index cfeb06669679..874c22134864 100644
--- a/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java
+++ b/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java
@@ -87,15 +87,15 @@ public ColumnarRowIterator copy(ColumnVector[] vectors) {
     }
 
     public ColumnarRowIterator mapping(
-            @Nullable PartitionInfo partitionInfo, @Nullable int[] columnMapping) {
-        if (partitionInfo != null || columnMapping != null) {
+            @Nullable PartitionInfo partitionInfo, @Nullable int[] indexMapping) {
+        if (partitionInfo != null || indexMapping != null) {
             VectorizedColumnBatch vectorizedColumnBatch = row.batch();
             ColumnVector[] vectors = vectorizedColumnBatch.columns;
             if (partitionInfo != null) {
                 vectors = VectorMappingUtils.createPartitionMappedVectors(partitionInfo, vectors);
             }
-            if (columnMapping != null) {
-                vectors = VectorMappingUtils.createMappedVectors(columnMapping, vectors);
+            if (indexMapping != null) {
+                vectors = VectorMappingUtils.createMappedVectors(indexMapping, vectors);
             }
             return copy(vectors);
         }