[FLINK-15726] [Blink Planner] [hotfix] Fix error message in

StreamExecTableSourceScan & BatchExecTableSourceScan This closes #10914
apache · Jan 22, 2020 · 772d83e · 772d83e
1 parent 6061372
commit 772d83e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...a/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala b/...a/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/...org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala b/...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.")
     }