flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bowen Li (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-6957) WordCountTable example cannot be run
Date Tue, 03 Oct 2017 22:17:01 GMT

     [ https://issues.apache.org/jira/browse/FLINK-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Bowen Li resolved FLINK-6957.
-----------------------------
    Resolution: Cannot Reproduce

> WordCountTable example cannot be run
> ------------------------------------
>
>                 Key: FLINK-6957
>                 URL: https://issues.apache.org/jira/browse/FLINK-6957
>             Project: Flink
>          Issue Type: Bug
>          Components: Examples, Table API & SQL
>    Affects Versions: 1.4.0
>            Reporter: Chesnay Schepler
>            Assignee: Bowen Li
>             Fix For: 1.4.0
>
>
> Running the example (with the fix for FLINK-6956 applied) gives the following exception:
> {code}
> Table program cannot be compiled. This is a bug. Please file an issue.
>         org.apache.flink.table.codegen.Compiler$class.compile(Compiler.scala:36)
>         org.apache.flink.table.runtime.MapRunner.compile(MapRunner.scala:28)
>         org.apache.flink.table.runtime.MapRunner.open(MapRunner.scala:42)
>         org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
>         org.apache.flink.api.common.operators.base.MapOperatorBase.executeOnCollections(MapOperatorBase.java:64)
>         org.apache.flink.api.common.operators.CollectionExecutor.executeUnaryOperator(CollectionExecutor.java:250)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:148)
>         org.apache.flink.api.common.operators.CollectionExecutor.executeUnaryOperator(CollectionExecutor.java:228)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:148)
>         org.apache.flink.api.common.operators.CollectionExecutor.executeUnaryOperator(CollectionExecutor.java:228)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:148)
>         org.apache.flink.api.common.operators.CollectionExecutor.executeUnaryOperator(CollectionExecutor.java:228)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:148)
>         org.apache.flink.api.common.operators.CollectionExecutor.executeUnaryOperator(CollectionExecutor.java:228)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:148)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:130)
>         org.apache.flink.api.common.operators.CollectionExecutor.executeDataSink(CollectionExecutor.java:181)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:157)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:130)
>         org.apache.flink.api.common.operators.CollectionExecutor.execute(CollectionExecutor.java:114)
>         org.apache.flink.api.java.CollectionEnvironment.execute(CollectionEnvironment.java:35)
>         org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:926)
>         org.apache.flink.api.java.DataSet.collect(DataSet.java:410)
>         org.apache.flink.api.java.DataSet.print(DataSet.java:1605)
>         org.apache.flink.table.examples.java.WordCountTable.main(WordCountTable.java:58)
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message