[flink] branch release-1.9 updated: [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan & BatchExecTableSourceScan

[dwysakowicz]

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

dwysakowicz pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new 772d83e  [FLINK-15726] [Blink Planner] [hotfix] Fix error message in 
StreamExecTableSourceScan & BatchExecTableSourceScan
772d83e is described below

commit 772d83e4911d5330d5c2e8fd80f5887adcc3edae
Author: Benoît Paris <benoit.paris....@gmail.com>
AuthorDate: Tue Jan 21 11:59:49 2020 +0100

    [FLINK-15726] [Blink Planner] [hotfix] Fix error message in
    StreamExecTableSourceScan & BatchExecTableSourceScan
    
    This closes #10914
---
 .../planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala    | 2 +-
 .../planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
 
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
index 5ab23d3..987a532 100644
--- 
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
+++ 
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
@@ -96,7 +96,7 @@ class BatchExecTableSourceScan(
     // check that declared and actual type of table source DataStream are 
identical
     if (inputDataType != 
TypeInfoDataTypeConverter.fromDataTypeToTypeInfo(producedDataType)) {
       throw new TableException(s"TableSource of type 
${tableSource.getClass.getCanonicalName} " +
-        s"returned a DataStream of data type $producedDataType that does not 
match with the " +
+        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.")
     }
diff --git 
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
 
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
index 746aad7..43bc291 100644
--- 
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
+++ 
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
@@ -108,7 +108,7 @@ class StreamExecTableSourceScan(
     // check that declared and actual type of table source DataStream are 
identical
     if (inputDataType != 
TypeInfoDataTypeConverter.fromDataTypeToTypeInfo(producedDataType)) {
       throw new TableException(s"TableSource of type 
${tableSource.getClass.getCanonicalName} " +
-        s"returned a DataStream of data type $producedDataType that does not 
match with the " +
+        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.")
     }