Nico Kruber created FLINK-9761: ---------------------------------- Summary: Potential buffer leak in PartitionRequestClientHandler during job failures Key: FLINK-9761 URL: https://issues.apache.org/jira/browse/FLINK-9761 Project: Flink Issue Type: Bug Components: Network Affects Versions: 1.5.0 Reporter: Nico Kruber Assignee: Nico Kruber Fix For: 1.6.0, 1.5.2
{{PartitionRequestClientHandler#stagedMessages}} may be accessed from multiple threads: 1) Netty's IO thread 2) During cancellation, {{PartitionRequestClientHandler.BufferListenerTask#notifyBufferDestroyed}} is called If {{PartitionRequestClientHandler.BufferListenerTask#notifyBufferDestroyed}} thinks, {{stagesMessages}} is empty, however, it will not install the {{stagedMessagesHandler}} that consumes and releases buffers from received messages. Unless some unexpected combination of code calls prevents this from happening, this would leak the non-recycled buffers. -- This message was sent by Atlassian JIRA (v7.6.3#76005)