Gabor Gevay created FLINK-2540:
----------------------------------
Summary: LocalBufferPool.requestBuffer gets into infinite loop
Key: FLINK-2540
URL:
https://issues.apache.org/jira/browse/FLINK-2540 Project: Flink
Issue Type: Bug
Reporter: Gabor Gevay
I'm trying to run a complicated computation that looks like this: [1].
One of the DataSource->Filter->Map chains finishes fine, but the other one freezes. Debugging shows that it is spinning in the while loop in LocalBufferPool.requestBuffer.
askToRecycle is false. Both numberOfRequestedMemorySegments and currentPoolSize is 128, so it never goes into that if either.
This is a stack trace: [2]
And here is the code, if you would like to run it: [3]. Unfortunately, I can't make it more minimal, becuase if I remove some operators, the problem disappears. The class to start is malom.Solver. (On first run, it calculates some lookuptables for a few minutes, and puts them into /tmp/movegen)
[1]
http://compalg.inf.elte.hu/~ggevay/flink/plan.txt[2]
http://compalg.inf.elte.hu/~ggevay/flink/stacktrace.txt[3]
https://github.com/ggevay/flink/tree/deadlock-malom--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
Locked
