diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
index bb040b0d4fd2..2e0a1319293f 100644
--- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
+++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/Expression.java
@@ -197,7 +197,7 @@ public static ReferencedField checkArgument(
                             String.format(
                                     "Referenced field '%s' is not in given fields: %s.",
                                     referencedFieldCheckForm, typeMapping.keySet()));
-            return new ReferencedField(referencedFieldCheckForm, fieldType, literals);
+            return new ReferencedField(referencedField, fieldType, literals);
         }
 
         public String field() {