[jira] [Commented] (FLINK-5357) WordCountTable fails

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-5357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15801347#comment-15801347 ] 

ASF GitHub Bot commented on FLINK-5357:
---------------------------------------

GitHub user twalthr opened a pull request:

    https://github.com/apache/flink/pull/3063

    [FLINK-5357] [table] Fix dropped projections

    In certain cases Calcite drops projections which is not what we want (e.g. using WordCount example). This PR adds explicit projections which are removed by optimizer rules later.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/twalthr/flink FLINK-5357

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/3063.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #3063
    
----
commit 0966b8f1fc60ecebeb0a36817c4f2dcb5f1547f6
Author: twalthr <tw...@apache.org>
Date:   2017-01-05T13:14:52Z

    [FLINK-5357] [table] Fix dropped projections

----


> WordCountTable fails
> --------------------
>
>                 Key: FLINK-5357
>                 URL: https://issues.apache.org/jira/browse/FLINK-5357
>             Project: Flink
>          Issue Type: Bug
>          Components: Table API & SQL
>            Reporter: Timo Walther
>            Assignee: Timo Walther
>
> The execution of org.apache.flink.table.examples.java.WordCountTable fails:
> {code}
> Exception in thread "main" org.apache.flink.table.api.TableException: POJO does not define field name: TMP_0
> 	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.DataSetCalc.translateToPlan(DataSetCalc.scala:110)
> 	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 org.apache.flink.table.examples.java.WordCountTable.main(WordCountTable.java:56)
> 	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.4#6332)