[
https://issues.apache.org/jira/browse/FLINK-17440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-17440.
----------------------------
Resolution: Fixed
Merged into master: 72f528d0cda2f51c5c71395ad619d49009af2f77
> Potential Buffer leak in output unspilling for unaligned checkpoints
> --------------------------------------------------------------------
>
> Key: FLINK-17440
> URL: https://issues.apache.org/jira/browse/FLINK-17440
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Reporter: Piotr Nowojski
> Assignee: Zhijiang
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.11.0
>
>
> {code}
> @Override
> public void PipelinedSubpartition#initializeState(ChannelStateReader
> stateReader) throws IOException, InterruptedException {
> for (ReadResult readResult = ReadResult.HAS_MORE_DATA; readResult ==
> ReadResult.HAS_MORE_DATA;) {
> BufferBuilder bufferBuilder =
> parent.getBufferPool().requestBufferBuilderBlocking();
> BufferConsumer bufferConsumer =
> bufferBuilder.createBufferConsumer();
> readResult = stateReader.readOutputData(subpartitionInfo,
> bufferBuilder); // <<<<<<<<<<<<<<<<<<<<<<<
> // check whether there are some states data filled in this time
> if (bufferConsumer.isDataAvailable()) {
> add(bufferConsumer, false, false);
> bufferBuilder.finish();
> } else {
> bufferConsumer.close();
> }
> }
> }
> {code}
> There is a memory leak in output unspilling in case of an exception coming
> from the {{stateReader}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
