flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Exception with Java Table API example
Date Mon, 13 Apr 2015 08:14:33 GMT
Can you post your pom.xml here: https://gist.github.com/ ?

You can also send it privately to me if you don't want to share it via the
mailing list.

On Mon, Apr 13, 2015 at 10:12 AM, Mohamed Nadjib MAMI <mami@iai.uni-bonn.de>
wrote:

>  Hello Robert,
>
> I'm not using Scala, no Scala dependency in my pom file.
>
> Thanks
>
>
> On 13.04.2015 09:31, Robert Metzger wrote:
>
> Hi,
>
>  the error looks like a mixup of the Scala versions.
> Are you adding any scala 2.11 dependencies in your pom?
>
>
>
> On Sun, Apr 12, 2015 at 9:35 PM, Mohamed Nadjib MAMI <mami@iai.uni-bonn.de
> > wrote:
>
>>  Hello,
>>
>> Suit to my previous email, apologize, the error was in: *Table table =
>> tableEnv.toTable(input);*
>>
>> Cheers,
>> Mohamed
>>
>>
>> On 12.04.2015 21:33, Mohamed Nadjib MAMI wrote:
>>
>> Hello all,
>>
>> I've just tried the example of Java Table API as-is on the docs but I'm
>> getting this exception:
>>
>> *Exception in thread "main" java.lang.NoSuchMethodError:
>> scala.runtime.BooleanRef.create(Z)Lscala/runtime/BooleanRef;*
>> *    at
>> org.apache.flink.api.table.trees.TreeNode.exists(TreeNode.scala:93)*
>> *    at
>> org.apache.flink.api.java.table.JavaBatchTranslator$$anonfun$createSelect$1.apply(JavaBatchTranslator.scala:265)*
>> *    at
>> org.apache.flink.api.java.table.JavaBatchTranslator$$anonfun$createSelect$1.apply(JavaBatchTranslator.scala:264)*
>> *    at
>> scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)*
>> *    at
>> scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)*
>> *    at
>> org.apache.flink.api.java.table.JavaBatchTranslator.createSelect(JavaBatchTranslator.scala:263)*
>> *    at
>> org.apache.flink.api.java.table.JavaBatchTranslator.createTable(JavaBatchTranslator.scala:52)*
>> *    at
>> org.apache.flink.api.java.table.JavaBatchTranslator.createTable(JavaBatchTranslator.scala:42)*
>> *    at
>> org.apache.flink.api.table.plan.PlanTranslator.createTable(PlanTranslator.scala:152)*
>> *    at
>> org.apache.flink.api.table.plan.PlanTranslator.createTable(PlanTranslator.scala:64)*
>> *    at org.apache.flink.api.java.table.Ta*
>> *bleEnvironment.toTable(TableEnvironment.scala:57)*
>> *    at Main.main(Main.java:20)*
>>
>> Line 20 is:
>>
>> *DataSet<WC> result = tableEnv.toSet(filtered, WC.class); *What could be
>> the reason firing the exception?
>>
>> The version used is 0.9-hadoop1-SNAPSHOT
>>
>> *. *Sincerely,
>> Mohamed
>>
>>
>>
>
>

Mime
View raw message