From 772d83e4911d5330d5c2e8fd80f5887adcc3edae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Beno=C3=AEt=20Paris?= Date: Tue, 21 Jan 2020 11:59:49 +0100 Subject: [PATCH] [FLINK-15726] [Blink Planner] [hotfix] Fix error message in StreamExecTableSourceScan & BatchExecTableSourceScan This closes #10914 --- .../plan/nodes/physical/batch/BatchExecTableSourceScan.scala | 2 +- .../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 5ab23d3769530..987a5320de9d2 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 746aad7bddf8e..43bc291d247c2 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.") }