You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Stephan Ewen <se...@apache.org> on 2014/08/08 15:00:42 UTC

Re: [GitHub] incubator-flink pull request: [FLINK-909], [FLINK945] Remove addit...

The memory problem was that the last superstep was sometimes not empty. The
result was then written to the released back channel.

When the iterative input came through a broadcast variable (the main input
of the operator came from the cache), a step with an empty bc variable, but
a full regular input happened. Depending on the user code, this may produce
results.