You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Mohamed Nadjib MAMI <ma...@iai.uni-bonn.de> on 2015/04/12 21:33:46 UTC
Exception with Java Table API example
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/
/
Re: Exception with Java Table API example
Posted by Robert Metzger <rm...@apache.org>.
Hi,
looks like you are mixing regular flink dependencies with hadoop1
dependencies.
Can you replace
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table</artifactId>
<version>0.9-hadoop1-SNAPSHOT</version>
<type>jar</type>
</dependency>
with
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table</artifactId>
<version>0.9-SNAPSHOT</version>
<type>jar</type>
</dependency>
On Mon, Apr 13, 2015 at 10:20 AM, Mohamed Nadjib MAMI <ma...@iai.uni-bonn.de>
wrote:
> Here it is:
> https://gist.github.com/MohamedNadjibMAMI/6dedbea0b33c64928d6a
>
>
> On 13.04.2015 10:14, Robert Metzger wrote:
>
> 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
>>>
>>>
>>>
>>
>>
>
>
Re: Exception with Java Table API example
Posted by Mohamed Nadjib MAMI <ma...@iai.uni-bonn.de>.
Well, it worked, I replaced 0.9-hadoop1-SNAPSHOT by of0.9-SNAPSHOT.
On 13.04.2015 10:20, Mohamed Nadjib MAMI wrote:
> Here it is: https://gist.github.com/MohamedNadjibMAMI/6dedbea0b33c64928d6a
>
> On 13.04.2015 10:14, Robert Metzger wrote:
>> 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 <ma...@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 <ma...@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/
>>>> /
>>>
>>>
>>
>>
>
Re: Exception with Java Table API example
Posted by Mohamed Nadjib MAMI <ma...@iai.uni-bonn.de>.
Here it is: https://gist.github.com/MohamedNadjibMAMI/6dedbea0b33c64928d6a
On 13.04.2015 10:14, Robert Metzger wrote:
> 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 <ma...@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 <ma...@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/
>>> /
>>
>>
>
>
Re: Exception with Java Table API example
Posted by Robert Metzger <rm...@apache.org>.
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 <ma...@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
>>
>>
>>
>
>
Re: Exception with Java Table API example
Posted by Mohamed Nadjib MAMI <ma...@iai.uni-bonn.de>.
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 <ma...@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/
>> /
>
>
Re: Exception with Java Table API example
Posted by Robert Metzger <rm...@apache.org>.
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 <ma...@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
>
>
>
Re: Exception with Java Table API example
Posted by Mohamed Nadjib MAMI <ma...@iai.uni-bonn.de>.
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/
> /