Nested Iterations supported in Flink?

Hello, I'm implementing an algorithm which requires nested iterations, and, from what I understood, this feature was not yet available in Flink [1], and my experiments with 2 nested bulk iterations seem to confirm that. However I came across a Flink unit test [2] using nested iterations, so

Re: Flink 0.9.0-milestone1 released

Woot! Great news! On Monday, April 13, 2015, Kostas Tzoumas wrote: > We are very excited to announce Flink 0.9.0-milestone1, a preview release > to give users early access to some Flink 0.9.0 features, including: > > - A Table API for SQL-like queries embedded in Java and Scala > - Gelly, Flink'

Flink 0.9.0-milestone1 released

We are very excited to announce Flink 0.9.0-milestone1, a preview release to give users early access to some Flink 0.9.0 features, including: - A Table API for SQL-like queries embedded in Java and Scala - Gelly, Flink's graph processing API - A Machine Learning library on Flink inspired by scikit

Re: Release date 0.9

Hey Sebastian, please contact Alexander Alexandrov (cc'ed) and ask about the Peel framework. It will help a lot with experimenting with both systems. A student in TUB (Mingling Qi) here has also done this comparison - you can have some input from him as well. Cheers, Asterios On Mon, Apr 13, 20

Re: Release date 0.9

Hi Sebastian, its great to hear that you're planning to do a seminar on data analytics platforms. We have closed the vote for a 0.9.0-milestone-1 release yesterday. I hope we are able to announce it today. Its a preview release only, but it contains all the latest features and its certainly possib

Release date 0.9

Hello everyone, we are having a seminar at HPI that is supposed to compare Flink and Spark. The students should implement solutions for different data analytics problems on both platforms. Since Flink is still moving a lot, we would like to have the students work on the latest version and mayb

Re: Exception with Java Table API example

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/ ?

Re: Exception with Java Table API example

Hi, looks like you are mixing regular flink dependencies with hadoop1 dependencies. Can you replace org.apache.flink flink-table 0.9-hadoop1-SNAPSHOT jar with org.apache.flink flink-table

Re: Exception with Java Table API example

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

Re: Exception with Java Table API example

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 wrote: > Hello Robert, > > I'm not using Scala, no Scala dependency in my pom file. > > Than

Re: Exception with Java Table API example

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 mai

Re: Exception with Java Table API example

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 wrote: > Hello, > > Suit to my previous email, apologize, the error was in: *Table table = > tableEnv.toTable(input);* > > Chee