[flink] 04/06: [hotfix][table-common] Fix logging in the table source validation procedure

[twalthr]

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

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

commit daee14f8a54a6e650c57ed93d960d505793f2c67
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Wed Jul 24 09:54:33 2019 +0200

    [hotfix][table-common] Fix logging in the table source validation procedure
---
 .../java/org/apache/flink/table/sources/TableSourceValidation.java  | 6 ++++--
 .../flink/table/plan/nodes/datastream/StreamTableSourceScan.scala   | 2 +-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSourceValidation.java
 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSourceValidation.java
index d93b87c..553c675 100644
--- 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSourceValidation.java
+++ 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSourceValidation.java
@@ -269,8 +269,10 @@ public class TableSourceValidation {
                        lookupFieldType(
                                producedDataType,
                                fieldName,
-                               String.format("Table field '%s' was not found 
in the return type $returnType of the " +
-                                       "TableSource.", fieldName)));
+                               String.format(
+                                       "Table field '%s' was not found in the 
return type %s of the TableSource.",
+                                       fieldName,
+                                       producedDataType)));
        }
 
        /** Look up a field by name in a {@link DataType}. */
diff --git 
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
 
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
index 77a1eae..ab2ef0f 100644
--- 
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
+++ 
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
@@ -103,7 +103,7 @@ class StreamTableSourceScan(
 
     // check that declared and actual type of table source DataStream are 
identical
     if (inputDataType != producedDataType) {
-      throw new TableException(s"TableSource of type 
${tableSource.getClass.getCanonicalName} " +
+      throw new TableException(s"TableSource of type 
${tableSource.getClass.getName} " +
         s"returned a DataStream of data type $inputDataType that does not 
match with the " +
         s"data type $producedDataType declared by the 
TableSource.getProducedDataType() method. " +
         s"Please validate the implementation of the TableSource.")