flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4111) Flink Table & SQL doesn't work in very simple example
Date Fri, 08 Jul 2016 07:58:11 GMT

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

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

Github user twalthr commented on a diff in the pull request:

    https://github.com/apache/flink/pull/2209#discussion_r70038156
  
    --- Diff: flink-libraries/flink-table/pom.xml ---
    @@ -148,80 +148,22 @@ under the License.
     						</goals>
     					</execution>
     				</executions>
    -				<configuration>
    -					<jvmArgs>
    -						<jvmArg>-Xms128m</jvmArg>
    -						<jvmArg>-Xmx512m</jvmArg>
    -					</jvmArgs>
    -					<compilerPlugins combine.children="append">
    -						<compilerPlugin>
    -							<groupId>org.scalamacros</groupId>
    -							<artifactId>paradise_${scala.version}</artifactId>
    -							<version>${scala.macros.version}</version>
    -						</compilerPlugin>
    --- End diff --
    
    Most of the dependencies I removed here are defined in `flink-scala`. Other Scala projects
like `flink-cep-scala` or `flink-gelly-scala` also do not have this.


> Flink Table & SQL doesn't work in very simple example
> -----------------------------------------------------
>
>                 Key: FLINK-4111
>                 URL: https://issues.apache.org/jira/browse/FLINK-4111
>             Project: Flink
>          Issue Type: Bug
>          Components: Table API & SQL
>    Affects Versions: 1.1.0
>            Reporter: Jark Wu
>            Assignee: Timo Walther
>             Fix For: 1.1.0
>
>
> I’m trying to use Flink Table 1.1-SNAPSHOT where I want to use Table API and SQL in
my project. But when I run the very simple example WordCountTable, I encountered the following
exception : 
> {code}
> Exception in thread "main" java.lang.NoSuchMethodError: org.apache.calcite.rel.logical.LogicalAggregate.getGroupSets()Lorg/apache/flink/shaded/com/google/common/collect/ImmutableList;
>   at org.apache.flink.api.table.plan.rules.dataSet.DataSetAggregateRule.matches(DataSetAggregateRule.scala:47)
>   at org.apache.calcite.plan.volcano.VolcanoRuleCall.matchRecurse(VolcanoRuleCall.java:269)
>   at org.apache.calcite.plan.volcano.VolcanoRuleCall.match(VolcanoRuleCall.java:253)
>   at org.apache.calcite.plan.volcano.VolcanoPlanner.fireRules(VolcanoPlanner.java:1542)
>   at org.apache.calcite.plan.volcano.VolcanoPlanner.registerImpl(VolcanoPlanner.java:1817)
>   at org.apache.calcite.plan.volcano.VolcanoPlanner.register(VolcanoPlanner.java:1038)
>   at org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(VolcanoPlanner.java:1058)
>   at org.apache.calcite.plan.volcano.VolcanoPlanner.changeTraits(VolcanoPlanner.java:723)
>   at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:331)
>   at org.apache.flink.api.table.BatchTableEnvironment.translate(BatchTableEnvironment.scala:250)
>   at org.apache.flink.api.scala.table.BatchTableEnvironment.toDataSet(BatchTableEnvironment.scala:139)
>   at org.apache.flink.api.scala.table.TableConversions.toDataSet(TableConversions.scala:41)
>   at com.alibaba.flink.examples.WordCountTable$.main(WordCountTable.scala:43)
>   at com.alibaba.flink.examples.WordCountTable.main(WordCountTable.scala)
> {code}
> It seems that something  wrong with our guava shade. Do you have any ideas? 
> My pom file and WordCountTable.scala are [here|https://gist.github.com/wuchong/9c1c0df3cb7453502abc4605f5347289].

> And I found someone have the same problem on stack overflow [http://stackoverflow.com/questions/37835408/org-apache-flink-api-table-tableexception-alias-on-field-reference-expression-e#comment63160086_37838816]



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message