This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch release-1.10 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4a8fa1ff6890b0ba62935b575afdd4a0dc860db1 Author: Dawid Wysakowicz <[email protected]> AuthorDate: Tue Dec 17 12:59:12 2019 +0100 [hotfix][table-planner-blink, tests] Fix produced data type of TestCollectionTableSource. --- .../table/planner/factories/utils/TestCollectionTableFactory.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/factories/utils/TestCollectionTableFactory.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/factories/utils/TestCollectionTableFactory.scala index 95ec047..8970ef3 100644 --- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/factories/utils/TestCollectionTableFactory.scala +++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/factories/utils/TestCollectionTableFactory.scala @@ -36,6 +36,7 @@ import org.apache.flink.table.functions.{AsyncTableFunction, TableFunction} import org.apache.flink.table.planner.factories.utils.TestCollectionTableFactory.{getCollectionSink, getCollectionSource} import org.apache.flink.table.sinks.{AppendStreamTableSink, BatchTableSink, StreamTableSink, TableSink} import org.apache.flink.table.sources.{BatchTableSource, LookupableTableSource, StreamTableSource, TableSource} +import org.apache.flink.table.types.DataType import org.apache.flink.types.Row import java.io.IOException @@ -162,7 +163,7 @@ object TestCollectionTableFactory { rowType) } - override def getReturnType: TypeInformation[Row] = rowType + override def getProducedDataType: DataType = schema.toRowDataType override def getTableSchema: TableSchema = { schema
