Hi, As far as I managed to isolate the cause of the error so far it has to do with some mismatch in the function call
val traitDefs:ImmutableList[RelTraitDef[_ <: RelTrait]] = config.getTraitDefs I am not sure thought why it is not working because when I tried to make a dummy test by creating a program and calling that function, everything works. Can it be that there is some overlapping between libraries that contain the ImmutableList type? google/common/collect/ImmutableList (with flink shaded)? As per the error "/apache/flink/shaded/calcite/com/google/common/collect/ImmutableList;" -----Original Message----- From: Maximilian Michels [mailto:m...@apache.org] Sent: Wednesday, July 20, 2016 11:52 AM To: dev@flink.apache.org Cc: Timo Walther Subject: Re: Flink Table & SQL doesn't work in very simple example 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-tabl >> e >> -tableexception-alias-on-field-reference-expression-e#comment63160086 >> _ >> 37838816 >> < >> http://stackoverflow.com/questions/37835408/org-apache-flink-api-tabl >> e >> -tableexception-alias-on-field-reference-expression-e#comment63160086 >> _ >> 37838816 >> > >> - Jark Wu >> >>
