RE: Flink Table & SQL doesn't work in very simple example

Radu Tudoran Tue, 19 Jul 2016 09:14:25 -0700

Hi,

I am not sure that this problem was solved. I am using the last pom to compile 
the table API.


I was trying to run a simple program.


ArrayList<Tuple3<Long, String, Integer>> input = new ArrayList<Tuple3<Long, 
String, Integer>>();
                input.add(new Tuple3<Long, String, Integer>(3L,"test",1));
                input.add(new Tuple3<Long, String, Integer>(5L,"test2",2));
                
                DataStream<Tuple3<Long, String, Integer>> ds = 
env.fromCollection(input);

StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);
                
                tableEnv.registerDataStream("Words", ds, "frequency, word, 
position");
                // run a SQL query on the Table and retrieve the result as a 
new Table
                Table result = tableEnv.sql(
                  "SELECT STREAM product, amount FROM Words WHERE frequency > 
2");
                


..and I get:

Exception in thread "main" java.lang.NoSuchMethodError: 
org.apache.calcite.tools.FrameworkConfig.getTraitDefs()Lorg/apache/flink/shaded/calcite/com/google/common/collect/ImmutableList;
        at 
org.apache.flink.api.table.FlinkPlannerImpl.<init>(FlinkPlannerImpl.scala:50)
        at 
org.apache.flink.api.table.StreamTableEnvironment.sql(StreamTableEnvironment.scala:127)
        at TestStreamSQL.main(TestStreamSQL.java:69)


Any thoughts on how this can be solved?


Dr. Radu Tudoran
Research Engineer - Big Data Expert
IT R&D Division


HUAWEI TECHNOLOGIES Duesseldorf GmbH
European Research Center
Riesstrasse 25, 80992 München

E-mail: radu.tudo...@huawei.com
Mobile: +49 15209084330
Telephone: +49 891588344173

HUAWEI TECHNOLOGIES Duesseldorf GmbH
Hansaallee 205, 40549 Düsseldorf, Germany, www.huawei.com
Registered Office: Düsseldorf, Register Court Düsseldorf, HRB 56063,
Managing Director: Bo PENG, Wanzhou MENG, Lifang CHEN
Sitz der Gesellschaft: Düsseldorf, Amtsgericht Düsseldorf, HRB 56063,
Geschäftsführer: Bo PENG, Wanzhou MENG, Lifang CHEN
This e-mail and its attachments contain confidential information from HUAWEI, 
which is intended only for the person or entity whose address is listed above. 
Any use of the information contained herein in any way (including, but not 
limited to, total or partial disclosure, reproduction, or dissemination) by 
persons other than the intended recipient(s) is prohibited. If you receive this 
e-mail in error, please notify the sender by phone or email immediately and 
delete it!


-----Original Message-----
From: Fabian Hueske [mailto:fhue...@gmail.com] 
Sent: Thursday, June 23, 2016 11:13 AM
To: dev@flink.apache.org
Subject: Re: Flink Table & SQL doesn't work in very simple example

Hi Jark Wu,

yes, that looks like a dependency issue.
Can you open a JIRA for it set "Fix Version" to 1.1.0. This issue should be 
resolved for the 1.1 release.

Thanks, Fabian

2016-06-22 3:52 GMT+02:00 Jark Wu <wuchong...@alibaba-inc.com>:

> Hi,
>
>
> 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 :
>
> 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)
>
>
> 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 < 
> 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
> <
> http://stackoverflow.com/questions/37835408/org-apache-flink-api-table
> -tableexception-alias-on-field-reference-expression-e#comment63160086_
> 37838816
> >
> - Jark Wu
>
>

RE: Flink Table & SQL doesn't work in very simple example

Reply via email to