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.

Reply via email to