Mailing-List: contact dev-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <97879173-02C5-46C0-96F8-C4A44EAA6E09@alibaba-inc.com>
References: <97879173-02C5-46C0-96F8-C4A44EAA6E09@alibaba-inc.com>
From: Fabian Hueske <fhueske@gmail.com>
Date: Thu, 23 Jun 2016 11:13:07 +0200
Message-ID: <CAAdrtT2_wV9+pe29eZ-WbZX2ZCFFutnvYHHKb3eEddPQiefdgg@mail.gmail.com>
Subject: Re: Flink Table & SQL doesn't work in very simple example
To: "dev@flink.apache.org" <dev@flink.apache.org>
Content-Type: multipart/alternative; boundary=001a114246a81793ad0535ee785c
archived-at: Thu, 23 Jun 2016 09:13:48 -0000

--001a114246a81793ad0535ee785c
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

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.wc@alibaba-inc.com>:

> Hi,
>
>
> I=E2=80=99m trying to use Flink Table 1.1-SNAPSHOT where I want to use Ta=
ble 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.matche=
s(DataSetAggregateRule.scala:47)
>   at
> org.apache.calcite.plan.volcano.VolcanoRuleCall.matchRecurse(VolcanoRuleC=
all.java:269)
>   at
> org.apache.calcite.plan.volcano.VolcanoRuleCall.match(VolcanoRuleCall.jav=
a:253)
>   at
> org.apache.calcite.plan.volcano.VolcanoPlanner.fireRules(VolcanoPlanner.j=
ava:1542)
>   at
> org.apache.calcite.plan.volcano.VolcanoPlanner.registerImpl(VolcanoPlanne=
r.java:1817)
>   at
> org.apache.calcite.plan.volcano.VolcanoPlanner.register(VolcanoPlanner.ja=
va:1038)
>   at
> org.apache.calcite.plan.volcano.VolcanoPlanner.ensureRegistered(VolcanoPl=
anner.java:1058)
>   at
> org.apache.calcite.plan.volcano.VolcanoPlanner.changeTraits(VolcanoPlanne=
r.java:723)
>   at
> org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:331)
>   at
> org.apache.flink.api.table.BatchTableEnvironment.translate(BatchTableEnvi=
ronment.scala:250)
>   at
> org.apache.flink.api.scala.table.BatchTableEnvironment.toDataSet(BatchTab=
leEnvironment.scala:139)
>   at
> org.apache.flink.api.scala.table.TableConversions.toDataSet(TableConversi=
ons.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 idea=
s?
>
> 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-ta=
bleexception-alias-on-field-reference-expression-e#comment63160086_37838816
> <
> http://stackoverflow.com/questions/37835408/org-apache-flink-api-table-ta=
bleexception-alias-on-field-reference-expression-e#comment63160086_37838816
> >
> - Jark Wu
>
>

--001a114246a81793ad0535ee785c--