[jira] [Resolved] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop

["Stephan Ewen (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stephan Ewen resolved FLINK-2540.
---------------------------------
    Resolution: Fixed

Fixed
  - 0.9.1 in a31f29480ace690ac59e3e29a8dd4832d078d2ab
  - 0.10 in 58421b848ac9190db3b7c86b5ee4f8a9fc977d90

> LocalBufferPool.requestBuffer gets into infinite loop
> -----------------------------------------------------
>
>                 Key: FLINK-2540
>                 URL: https://issues.apache.org/jira/browse/FLINK-2540
>             Project: Flink
>          Issue Type: Bug
>          Components: Core
>            Reporter: Gabor Gevay
>            Assignee: Ufuk Celebi
>            Priority: Blocker
>             Fix For: 0.10, 0.9.1
>
>
> 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)