diff --git a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java
index ffb364b0ef..e04416db74 100644
--- a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java
+++ b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java
@@ -686,7 +686,9 @@ private static TimestampData castToTimestamp(Object object, String timezone) {
                     LocalDateTime.ofInstant(
                             ((ZonedTimestampData) object).toInstant(), ZoneId.of(timezone)));
         } else {
-            return TimestampData.fromLocalDateTime(LocalDateTime.parse(String.valueOf(object)));
+            throw new IllegalArgumentException(
+                    String.format(
+                            "Unable to implicitly coerce object `%s` as a TIMESTAMP.", object));
         }
     }
 }