diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSourceUtils.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSourceUtils.java
index a78f9f52ce08a..7215d252c52df 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSourceUtils.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSourceUtils.java
@@ -436,10 +436,10 @@ public static void validateAndApplyMetadata(
         if (!(source instanceof SupportsReadingMetadata)) {
             throw new ValidationException(
                     String.format(
-                            "Table '%s' declares metadata columns, but the underlying %s doesn't implement "
+                            "Table '%s' declares metadata columns, but the underlying DynamicTableSource class '%s' doesn't implement "
                                     + "the %s interface. Therefore, metadata cannot be read from the given source.",
-                            source.asSummaryString(),
-                            DynamicTableSource.class.getSimpleName(),
+                            tableDebugName,
+                            source.getClass().getName(),
                             SupportsReadingMetadata.class.getSimpleName()));
         }