You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/01/22 12:18:16 UTC
[flink] branch release-1.9 updated: [FLINK-15726] [Blink Planner]
[hotfix] Fix error message in StreamExecTableSourceScan &
BatchExecTableSourceScan
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 <be...@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.")
}