This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1b27f16f8737768e23f802ef0c2fe03e721df232
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.")
