flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vasiliki Kalavri <vasilikikala...@gmail.com>
Subject Re: Bug while using Table API
Date Wed, 04 May 2016 11:34:23 GMT
Hi Simone,

I tried reproducing your problem with no luck.
I ran the WordCountTable example using sbt quickstart with Flink
1.1-SNAPSHOT and Scala 2.10 and it worked fine.
Can you maybe post the code you tried?

Thanks,
-Vasia.

On 4 May 2016 at 11:20, Simone Robutti <simone.robutti@radicalbit.io> wrote:

> Hello,
>
> while trying my first job using the Table API I got blocked by this error:
>
> Exception in thread "main" java.lang.NoSuchFieldError: RULES
> at
> org.apache.flink.api.table.plan.rules.FlinkRuleSets$.<init>(FlinkRuleSets.scala:148)
> at
> org.apache.flink.api.table.plan.rules.FlinkRuleSets$.<clinit>(FlinkRuleSets.scala)
> at
> org.apache.flink.api.table.BatchTableEnvironment.translate(BatchTableEnvironment.scala:212)
> at
> org.apache.flink.api.scala.table.BatchTableEnvironment.toDataSet(BatchTableEnvironment.scala:141)
> at org.example.Job$.main(Job.scala:64)
> at org.example.Job.main(Job.scala)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
>
>
> This happens with every Job. Right now I'm trying with the WordCount
> example from the documentation. I'm using SBT quickstart project with
> version 1.1-SNAPSHOT. I can actually access the "StreamRules.RULES" field
> directly so it is there, but if I try to access DATASTREAM_OPT_RULES the
> same error as the one reported is raised.
>
> I tried both with Scala 2.11 and Scala 2.10.
>
>
>

Mime
View raw message