[ 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)