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

Posted to dev@flink.apache.org by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/12/03 07:15:00 UTC

[jira] [Created] (FLINK-15030) Potential deadlock for bounded blocking ResultPartition.

Yingjie Cao created FLINK-15030:
-----------------------------------

             Summary: Potential deadlock for bounded blocking ResultPartition.
                 Key: FLINK-15030
                 URL: https://issues.apache.org/jira/browse/FLINK-15030
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Network
    Affects Versions: 1.9.1, 1.9.0
            Reporter: Yingjie Cao


Currently, the BoundedBlockingSubpartition relies on the add of the next BufferConsumer to flush and recycle the previous one, which means we need at least (numsubpartition + 1) buffers to make the bounded blocking ResultPartition work. However, the ResultPartitionFactory gives only (numsubpartition) required buffers to the BoundedBlockingSubpartition which may lead to deadlock.

This problem exists only in version 1.9. In version 1.10 (master), this problem has been fixed by this commit: 2c8b4ef572f05bf4740b7e204af1e5e709cd945c.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)