CC Timo who I know is working on Table API and SQL.
On Tue, Jul 19, 2016 at 6:14 PM, Radu Tudoran <radu.tudo...@huawei.com> wrote:
> 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
>>
>>
