[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske closed FLINK-6476. -------------------------------- Resolution: Implemented Fix Version/s: 1.4.0 1.3.0 Implemented for 1.3 with 28a89d1cac79063245bbc1ad9d262e3bc94b17b9 Implemented for 1.4 with 6cd98a9b6f223bc665831e4ff3626c98aed9b272 > Table environment register row data stream > ------------------------------------------ > > Key: FLINK-6476 > URL: https://issues.apache.org/jira/browse/FLINK-6476 > Project: Flink > Issue Type: Improvement > Components: Table API & SQL > Environment: java/scala > Reporter: radu > Assignee: radu > Labels: feature, patch > Fix For: 1.3.0, 1.4.0 > > > Registering as table source streams with Row is currently not possible: > Java: > DataStream<Row> ds = ... > tableEnv.registerDataStream("MyTableRow", ds, "a, b, c ..."); > org.apache.flink.table.api.TableException: Source of type Row(f0: Integer, > f1: Long, f2: Integer, f3: String, f4: Integer) cannot be converted into > Table. > at > org.apache.flink.table.api.TableEnvironment.getFieldInfo(TableEnvironment.scala:680) > at > org.apache.flink.table.api.StreamTableEnvironment.registerDataStreamInternal(StreamTableEnvironment.scala:363) > at > org.apache.flink.table.api.java.StreamTableEnvironment.registerDataStream(StreamTableEnvironment.scala:133) > at > org.apache.flink.table.api.java.stream.sql.SqlITCase.testRow2(SqlITCase.java:92) > Scala: > val ds:DataStream[Row] = ... > tableEnv.registerDataStream("MyTableRow", ds, "a, b, c, d, e"); > org.apache.flink.api.java.typeutils.GenericTypeInfo cannot be cast to > org.apache.flink.api.common.typeutils.CompositeType > This can be supported by extending the in the > org.apache.flink.table.api.TableEnvironment > getFieldInfo() > and by constructing the StreamTableSource correspondingly -- This message was sent by Atlassian JIRA (v6.3.15#6346)