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)
