Exception with Java Table API example

[Mohamed Nadjib MAMI]

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.TableEnvironment.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

[Mohamed Nadjib MAMI]

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.TableEnvironment.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

[rmetzger0]

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 <[hidden email]> 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.TableEnvironment.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

[Mohamed Nadjib MAMI]

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 <[hidden email]> 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.TableEnvironment.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

[rmetzger0]

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 <[hidden email]> 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 <[hidden email]> 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.TableEnvironment.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

[Mohamed Nadjib MAMI]

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 <[hidden email]> 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 <[hidden email]> 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.TableEnvironment.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

[rmetzger0]

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 <[hidden email]> 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 <[hidden email]> 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 <[hidden email]> 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.TableEnvironment.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

[Mohamed Nadjib MAMI]

Well, it worked, I replaced 0.9-hadoop1-SNAPSHOT by of 0.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 <[hidden email]> 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 <[hidden email]> 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.TableEnvironment.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

[hagersaleh]

want link explain Jave Table API

On Sunday, April 12, 2015 9:34 PM, Mohamed Nadjib MAMI [via Apache Flink (Incubator) User Mailing List archive.] <[hidden email]> 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.TableEnvironment.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

---

If you reply to this email, your message will be added to the discussion below:

http://apache-flink-incubator-user-mailing-list-archive.2336050.n4.nabble.com/Exception-with-Java-Table-API-example-tp988.html

To start a new topic under Apache Flink (Incubator) User Mailing List archive., email [hidden email]
To unsubscribe from Apache Flink (Incubator) User Mailing List archive., click here.
NAML