flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: [GitHub] incubator-flink pull request: [FLINK-909], [FLINK945] Remove addit...
Date Fri, 08 Aug 2014 13:00:42 GMT
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.

Mime
View raw message