(flink) branch master updated: [FLINK-38192][table] Improve DynamicSourceUtils exception msg

[guoweijie]

This is an automated email from the ASF dual-hosted git repository.

reswqa pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 570cb32dc1e [FLINK-38192][table] Improve DynamicSourceUtils exception 
msg
570cb32dc1e is described below

commit 570cb32dc1e1a365352b2c6c8abb7053b6aea3a8
Author: Arvind Kandpal <arvind.kand...@ksolves.com>
AuthorDate: Tue May 19 11:43:54 2026 +0530

    [FLINK-38192][table] Improve DynamicSourceUtils exception msg
---
 .../apache/flink/table/planner/connectors/DynamicSourceUtils.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 a78f9f52ce0..7215d252c52 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 final class DynamicSourceUtils {
         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()));
         }