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 b575f0916a09b..1e01200a6f645 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,11 @@ 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 %s class %s doesn't implement "
                                     + "the %s interface. Therefore, metadata cannot be read from the given source.",
                             source.asSummaryString(),
                             DynamicTableSource.class.getSimpleName(),
+                            source.getClass().getName(),
                             SupportsReadingMetadata.class.getSimpleName()));
         }