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 38387c47fe5ce..f5a222b89566d 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 @@ -103,7 +103,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.") }