zhijiangW commented on pull request #12912: URL: https://github.com/apache/flink/pull/12912#issuecomment-661684125
> For the second point, I mean if the cleanup of channels (sort by channel id for example) in the same order in the two threads, would that resolve the deadlock problem as well. @curcur thanks for the explanation and I got your point now. But it is not the case of current deadlock. In current situation, the two threads will not cleanup input channels concurrently. Actually only one thread will release channels, but the other thread will recycle buffers to further touch the internal lock of respective input channel. So we can not handle the sort or control anything for the recycled buffers which was maintained inside `CachedBufferStorage` in this case. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
