On Mon, Jun 15, 2015 at 3:30 PM, Aljoscha Krettek <aljos...@apache.org> wrote:
> Regarding 1), thats why I said "bugs and features". :D But I think of it as > a bug, since people will normally set in in the flink-conf.yaml on the > master and assume that it works. That's what I assumed and it took me a > while to figure out that the task managers don't respect this setting. > > Regarding 3), if you think about it, this could never work. The state > handle cleanup logic happens purely on the JobManager. So what happens is > that the TaskManagers create state in some directory, let's say > /tmp/checkpoints, on the TaskManager. For cleanup, the JobManager gets the > state handle and calls discard (on the JobManager), this tries to cleanup > the state in /tmp/checkpoints, but of course, there is nothing there since > we are still on the JobManager. > Release blocker, are you going to fix it today?