[ https://issues.apache.org/jira/browse/FLINK-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859445#comment-15859445 ]
ASF GitHub Bot commented on FLINK-5662: --------------------------------------- Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3277#discussion_r100297140 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala --- @@ -19,27 +19,20 @@ package org.apache.flink.table.plan.nodes.datastream import org.apache.calcite.rel.RelNode -import org.apache.flink.api.common.typeinfo.TypeInformation -import org.apache.flink.table.plan.nodes.FlinkRel import org.apache.flink.streaming.api.datastream.DataStream import org.apache.flink.table.api.StreamTableEnvironment +import org.apache.flink.table.plan.nodes.FlinkRel +import org.apache.flink.types.Row trait DataStreamRel extends RelNode with FlinkRel { /** * Translates the FlinkRelNode into a Flink operator. * * @param tableEnv The [[StreamTableEnvironment]] of the translated Table. - * @param expectedType specifies the type the Flink operator should return. The type must - * have the same arity as the result. For instance, if the - * expected type is a RowTypeInfo this method will return a DataSet of - * type Row. If the expected type is Tuple2, the operator will return - * a Tuple2 if possible. Row otherwise. * @return DataStream of type expectedType or RowTypeInfo --- End diff -- DataStream of Row > Alias in front of output fails > ------------------------------ > > Key: FLINK-5662 > URL: https://issues.apache.org/jira/browse/FLINK-5662 > Project: Flink > Issue Type: Bug > Components: Table API & SQL > Affects Versions: 1.2.0 > Reporter: Timo Walther > Assignee: Timo Walther > > Neither of the following snippets works: > {code} > public static void main(String[] args) throws Exception { > final ExecutionEnvironment env = > ExecutionEnvironment.getExecutionEnvironment(); > DataSet<String> text = ... > BatchTableEnvironment tEnv = TableEnvironment.getTableEnvironment(env); > // Table t = tEnv.fromDataSet(text, "text").select("text AS line"); > // Table t = tEnv.fromDataSet(text, "text").as("line"); > Table t = tEnv.fromDataSet(text, "text").select("text AS > line").select("line AS line"); > tEnv.toDataSet(t, MyPojo.class).print(); > } > public static class MyPojo { > public String line; > } > {code} > {code} > Exception in thread "main" org.apache.flink.table.api.TableException: POJO > does not define field name: text > at > org.apache.flink.table.typeutils.TypeConverter$$anonfun$2.apply(TypeConverter.scala:85) > at > org.apache.flink.table.typeutils.TypeConverter$$anonfun$2.apply(TypeConverter.scala:81) > at scala.collection.immutable.List.foreach(List.scala:318) > at > org.apache.flink.table.typeutils.TypeConverter$.determineReturnType(TypeConverter.scala:81) > at > org.apache.flink.table.plan.nodes.dataset.BatchScan.convertToExpectedType(BatchScan.scala:69) > at > org.apache.flink.table.plan.nodes.dataset.DataSetScan.translateToPlan(DataSetScan.scala:61) > at > org.apache.flink.table.api.BatchTableEnvironment.translate(BatchTableEnvironment.scala:305) > at > org.apache.flink.table.api.BatchTableEnvironment.translate(BatchTableEnvironment.scala:289) > at > org.apache.flink.table.api.java.BatchTableEnvironment.toDataSet(BatchTableEnvironment.scala:146) > at groupId.WordCount.main(WordCount.java:67) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147) > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)