flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Nested Iterations supported in Flink?
Date Tue, 14 Apr 2015 13:11:56 GMT
Hi Benoît!

You are right, the nested iterations are currently not supported.

The test you found actually checks that the Optimizer gives a good error
message when encountering nested iterations.

Can you write your program as one iterations (the inner) and start the
program multiple times to simulate the nesting?

Greetings,
Stephan


On Tue, Apr 14, 2015 at 8:11 AM, Benoît Hanotte <
benoit.jc.hanotte@campus.tu-berlin.de> wrote:

> 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 I'm now a bit
> confused. Could you please give me some insight on what is supported or not
> in the current state of the project?
>
> Thanks!
>
> Benoît.
>
> [1] http://mail-archives.apache.org/mod_mbox/flink-user/
> 201411.mbox/%3CCANC1h_tpNFWwrnm14+Et1yBvkQPQ1-pfk=
> iUPP5Un90ZgUGeyg@mail.gmail.com%3E
> [2] https://github.com/apache/flink/blob/master/flink-
> optimizer/src/test/java/org/apache/flink/optimizer/
> NestedIterationsTest.java
>

Mime
View raw message