You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/07/24 10:13:15 UTC
[flink] branch master updated: [FLINK-13351][table-blink-planner]
Clean up duplicate case clause for ROW in FlinkTypeFactory.toLogicalType
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 64ca5e4 [FLINK-13351][table-blink-planner] Clean up duplicate case clause for ROW in FlinkTypeFactory.toLogicalType
64ca5e4 is described below
commit 64ca5e4d41722fab109eb4883ce6817c265488aa
Author: LouisXu <xu...@163.com>
AuthorDate: Mon Jul 22 16:58:53 2019 +0800
[FLINK-13351][table-blink-planner] Clean up duplicate case clause for ROW in FlinkTypeFactory.toLogicalType
This closes #9196
---
.../org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala
index 3dc737d..9bd22c8 100644
--- a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala
+++ b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala
@@ -480,13 +480,7 @@ object FlinkTypeFactory {
genericRelDataType.genericType
case ROW if relDataType.isInstanceOf[RelRecordType] =>
- val recordType = relDataType.asInstanceOf[RelRecordType]
- RowType.of(
- recordType.getFieldList.map(_.getType).map(toLogicalType).toArray,
- recordType.getFieldNames.toSeq.toArray)
-
- case ROW if relDataType.isInstanceOf[RelRecordType] =>
- toLogicalRowType(relDataType.asInstanceOf[RelRecordType])
+ toLogicalRowType(relDataType)
case MULTISET => new MultisetType(toLogicalType(relDataType.getComponentType))