[ https://issues.apache.org/jira/browse/FLINK-5662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854347#comment-15854347 ]
ASF GitHub Bot commented on FLINK-5662: --------------------------------------- Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3277 I forgot to test TableSinks. I will do this tomorrow. > 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)